git.sur5r.net Git - openldap/blob - servers/slapd/back-sql/init.c

   1 /*
   2  *       Copyright 1999, Dmitry Kovalev <mit@openldap.org>, All rights reserved.
   3  *
   4  *       Redistribution and use in source and binary forms are permitted only
   5  *       as authorized by the OpenLDAP Public License.  A copy of this
   6  *       license is available at http://www.OpenLDAP.org/license.html or
   7  *       in file LICENSE in the top-level directory of the distribution.
   8  */
   9
  10 #include "portable.h"
  11
  12 #ifdef SLAPD_SQL
  13
  14 #include <stdio.h>
  15 #include <sys/types.h>
  16 #include "slap.h"
  17 #include "back-sql.h"
  18 #include "sql-wrap.h"
  19 #include "schema-map.h"
  20 #include "util.h"
  21
  22 #ifdef SLAPD_SQL_DYNAMIC
  23
  24 int backsql_LTX_init_module(int argc, char *argv[]) {
  25     BackendInfo bi;
  26
  27     memset( &bi, '\0', sizeof(bi) );
  28     bi.bi_type = "sql";
  29     bi.bi_init = backbacksql_initialize;
  30
  31     backend_add(&bi);
  32     return 0;
  33 }
  34
  35 #endif /* SLAPD_SHELL_DYNAMIC */
  36
  37 int sql_back_initialize(
  38     BackendInfo *bi
  39 )
  40 {
  41  Debug(LDAP_DEBUG_TRACE,"==>backsql_initialize()\n",0,0,0);
  42         bi->bi_open = 0;
  43         bi->bi_config = 0;
  44         bi->bi_close = 0;
  45         bi->bi_destroy = 0;
  46
  47         bi->bi_db_init = backsql_db_init;
  48         bi->bi_db_config = backsql_db_config;
  49         bi->bi_db_open = backsql_db_open;
  50         bi->bi_db_close = backsql_db_close;
  51         bi->bi_db_destroy = backsql_db_destroy;
  52
  53 #ifdef BACKSQL_ALL_DONE
  54         bi->bi_op_abandon = backsql_abandon;
  55         bi->bi_op_compare = backsql_compare;
  56 #else
  57         bi->bi_op_abandon = 0;
  58         bi->bi_op_compare = 0;
  59 #endif
  60         bi->bi_op_bind = backsql_bind;
  61         bi->bi_op_unbind = backsql_unbind;
  62         bi->bi_op_search = backsql_search;
  63         bi->bi_op_modify = backsql_modify;
  64         bi->bi_op_modrdn = backsql_modrdn;
  65         bi->bi_op_add = backsql_add;
  66         bi->bi_op_delete = backsql_delete;
  67
  68         bi->bi_acl_group = 0;
  69
  70         bi->bi_connection_init = 0;
  71         bi->bi_connection_destroy = 0;
  72
  73         Debug(LDAP_DEBUG_TRACE,"<==backsql_initialize()\n",0,0,0);
  74         return 0;
  75 }
  76
  77
  78 int backsql_destroy ( BackendInfo *bi )
  79 {
  80  Debug(LDAP_DEBUG_TRACE,"==>backsql_destroy()\n",0,0,0);
  81  Debug(LDAP_DEBUG_TRACE,"<==backsql_destroy()\n",0,0,0);
  82  return 0;
  83 }
  84
  85 int backsql_db_init(BackendDB *bd)
  86 {
  87  backsql_info *si;
  88
  89  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_init()\n",0,0,0);
  90  si = (backsql_info *) ch_calloc( 1, sizeof(backsql_info) );
  91  ldap_pvt_thread_mutex_init(&si->dbconn_mutex);
  92  ldap_pvt_thread_mutex_init(&si->schema_mutex);
  93  backsql_init_db_env(si);
  94
  95  bd->be_private=si;
  96  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_init()\n",0,0,0);
  97  return 0;
  98 }
  99
 100 int backsql_db_destroy(BackendDB *bd)
 101 {
 102  backsql_info *si=(backsql_info*)bd->be_private;
 103
 104  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_destroy()\n",0,0,0);
 105  ldap_pvt_thread_mutex_lock(&si->dbconn_mutex);
 106  backsql_free_db_env(si);
 107  ldap_pvt_thread_mutex_unlock(&si->dbconn_mutex);
 108  ldap_pvt_thread_mutex_lock(&si->schema_mutex);
 109  backsql_destroy_schema_map(si);
 110  ldap_pvt_thread_mutex_unlock(&si->schema_mutex);
 111  ldap_pvt_thread_mutex_destroy(&si->schema_mutex);
 112  ldap_pvt_thread_mutex_destroy(&si->dbconn_mutex);
 113  free(si->dbname);
 114  free(si->dbuser);
 115  if (si->dbpasswd)
 116   free(si->dbpasswd);
 117  if (si->dbhost)
 118   free(si->dbhost);
 119  if (si->upper_func)
 120   free(si->upper_func);
 121  free(si->subtree_cond);
 122  free(si->oc_query);
 123  free(si->at_query);
 124  free(si->insentry_query);
 125  free(si->delentry_query);
 126  free(si);
 127  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_destroy()\n",0,0,0);
 128  return 0;
 129 }
 130
 131 int backsql_db_open (BackendDB *bd)
 132 {
 133  backsql_info *si=(backsql_info*)bd->be_private;
 134  Connection tmp;
 135  SQLHDBC dbh;
 136  int idq_len;
 137
 138  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_open(): testing RDBMS connection\n",0,0,0);
 139  if (si->dbname==NULL)
 140  {
 141   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): datasource name not specified (use dbname directive in slapd.conf)\n",0,0,0);
 142   return 1;
 143  }
 144  if (si->dbuser==NULL)
 145  {
 146   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): user name not specified (use dbuser directive in slapd.conf)\n",0,0,0);
 147   return 1;
 148  }
 149  if (si->subtree_cond==NULL)
 150  {
 151   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): subtree search SQL condition not specified (use subtree_cond directive in slapd.conf)\n",0,0,0);
 152   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' as default\n",backsql_def_subtree_cond,0,0);
 153   si->subtree_cond=ch_strdup(backsql_def_subtree_cond);
 154  }
 155  if (si->oc_query==NULL)
 156  {
 157   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): objectclass mapping SQL statement not specified (use oc_query directive in slapd.conf)\n",0,0,0);
 158   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_oc_query,0,0);
 159   si->oc_query=ch_strdup(backsql_def_oc_query);
 160  }
 161  if (si->at_query==NULL)
 162  {
 163   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): attribute mapping SQL statement not specified (use at_query directive in slapd.conf)\n",0,0,0);
 164   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_at_query,0,0);
 165   si->at_query=ch_strdup(backsql_def_at_query);
 166  }
 167  if (si->insentry_query==NULL)
 168  {
 169   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): entry insertion SQL statement not specified (use insentry_query directive in slapd.conf)\n",0,0,0);
 170   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_insentry_query,0,0);
 171   si->insentry_query=ch_strdup(backsql_def_insentry_query);
 172  }
 173  if (si->delentry_query==NULL)
 174  {
 175   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): entry deletion SQL statement not specified (use delentry_query directive in slapd.conf)\n",0,0,0);
 176   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_delentry_query,0,0);
 177   si->delentry_query=ch_strdup(backsql_def_delentry_query);
 178  }
 179  si->id_query=NULL;
 180  idq_len=0;
 181  if (si->upper_func==NULL)
 182  {
 183   si->id_query=backsql_strcat(si->id_query,&idq_len,backsql_id_query,"dn=?",NULL);
 184  }
 185  else
 186   {
 187    si->id_query=backsql_strcat(si->id_query,&idq_len,backsql_id_query,si->upper_func,"(dn)=",si->upper_func,"(?)",NULL);
 188   }
 189  tmp.c_connid=-1;
 190  dbh=backsql_get_db_conn(bd,&tmp);
 191  if (!dbh)
 192  {
 193   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): connection failed, exiting\n",0,0,0);
 194   return 1;
 195  }
 196  backsql_free_db_conn(bd,&tmp);
 197  if (!si->schema_loaded)
 198  {
 199   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): test failed, schema map not loaded - exiting\n",0,0,0);
 200   return 1;
 201  }
 202  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_open(): test succeeded, schema map loaded\n",0,0,0);
 203  return 0;
 204 }
 205
 206 int backsql_db_close(BackendDB *bd)
 207 {
 208  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_close()\n",0,0,0);
 209  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_close()\n",0,0,0);
 210  return 0;
 211 }
 212
 213 #endif /* SLAPD_SQL */