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         bi->bi_chk_referrals = 0;
  70
  71         bi->bi_connection_init = 0;
  72         bi->bi_connection_destroy = 0;
  73
  74         Debug(LDAP_DEBUG_TRACE,"<==backsql_initialize()\n",0,0,0);
  75         return 0;
  76 }
  77
  78
  79 int backsql_destroy ( BackendInfo *bi )
  80 {
  81  Debug(LDAP_DEBUG_TRACE,"==>backsql_destroy()\n",0,0,0);
  82  Debug(LDAP_DEBUG_TRACE,"<==backsql_destroy()\n",0,0,0);
  83  return 0;
  84 }
  85
  86 int backsql_db_init(BackendDB *bd)
  87 {
  88  backsql_info *si;
  89
  90  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_init()\n",0,0,0);
  91  si = (backsql_info *) ch_calloc( 1, sizeof(backsql_info) );
  92  ldap_pvt_thread_mutex_init(&si->dbconn_mutex);
  93  ldap_pvt_thread_mutex_init(&si->schema_mutex);
  94  backsql_init_db_env(si);
  95
  96  bd->be_private=si;
  97  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_init()\n",0,0,0);
  98  return 0;
  99 }
 100
 101 int backsql_db_destroy(BackendDB *bd)
 102 {
 103  backsql_info *si=(backsql_info*)bd->be_private;
 104
 105  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_destroy()\n",0,0,0);
 106  ldap_pvt_thread_mutex_lock(&si->dbconn_mutex);
 107  backsql_free_db_env(si);
 108  ldap_pvt_thread_mutex_unlock(&si->dbconn_mutex);
 109  ldap_pvt_thread_mutex_lock(&si->schema_mutex);
 110  backsql_destroy_schema_map(si);
 111  ldap_pvt_thread_mutex_unlock(&si->schema_mutex);
 112  ldap_pvt_thread_mutex_destroy(&si->schema_mutex);
 113  ldap_pvt_thread_mutex_destroy(&si->dbconn_mutex);
 114  free(si->dbname);
 115  free(si->dbuser);
 116  if (si->dbpasswd)
 117   free(si->dbpasswd);
 118  if (si->dbhost)
 119   free(si->dbhost);
 120  if (si->upper_func)
 121   free(si->upper_func);
 122  free(si->subtree_cond);
 123  free(si->oc_query);
 124  free(si->at_query);
 125  free(si->insentry_query);
 126  free(si->delentry_query);
 127  free(si);
 128  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_destroy()\n",0,0,0);
 129  return 0;
 130 }
 131
 132 int backsql_db_open (BackendDB *bd)
 133 {
 134  backsql_info *si=(backsql_info*)bd->be_private;
 135  Connection tmp;
 136  SQLHDBC dbh;
 137  int idq_len;
 138
 139  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_open(): testing RDBMS connection\n",0,0,0);
 140  if (si->dbname==NULL)
 141  {
 142   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): datasource name not specified (use dbname directive in slapd.conf)\n",0,0,0);
 143   return 1;
 144  }
 145  if (si->dbuser==NULL)
 146  {
 147   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): user name not specified (use dbuser directive in slapd.conf)\n",0,0,0);
 148   return 1;
 149  }
 150  if (si->subtree_cond==NULL)
 151  {
 152   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): subtree search SQL condition not specified (use subtree_cond directive in slapd.conf)\n",0,0,0);
 153   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' as default\n",backsql_def_subtree_cond,0,0);
 154   si->subtree_cond=ch_strdup(backsql_def_subtree_cond);
 155  }
 156  if (si->oc_query==NULL)
 157  {
 158   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): objectclass mapping SQL statement not specified (use oc_query directive in slapd.conf)\n",0,0,0);
 159   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_oc_query,0,0);
 160   si->oc_query=ch_strdup(backsql_def_oc_query);
 161  }
 162  if (si->at_query==NULL)
 163  {
 164   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): attribute mapping SQL statement not specified (use at_query directive in slapd.conf)\n",0,0,0);
 165   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_at_query,0,0);
 166   si->at_query=ch_strdup(backsql_def_at_query);
 167  }
 168  if (si->insentry_query==NULL)
 169  {
 170   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): entry insertion SQL statement not specified (use insentry_query directive in slapd.conf)\n",0,0,0);
 171   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_insentry_query,0,0);
 172   si->insentry_query=ch_strdup(backsql_def_insentry_query);
 173  }
 174  if (si->delentry_query==NULL)
 175  {
 176   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): entry deletion SQL statement not specified (use delentry_query directive in slapd.conf)\n",0,0,0);
 177   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_delentry_query,0,0);
 178   si->delentry_query=ch_strdup(backsql_def_delentry_query);
 179  }
 180  si->id_query=NULL;
 181  idq_len=0;
 182  if (si->upper_func==NULL)
 183  {
 184   si->id_query=backsql_strcat(si->id_query,&idq_len,backsql_id_query,"dn=?",NULL);
 185  }
 186  else
 187   {
 188    si->id_query=backsql_strcat(si->id_query,&idq_len,backsql_id_query,si->upper_func,"(dn)=",si->upper_func,"(?)",NULL);
 189   }
 190  tmp.c_connid=-1;
 191  dbh=backsql_get_db_conn(bd,&tmp);
 192  if (!dbh)
 193  {
 194   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): connection failed, exiting\n",0,0,0);
 195   return 1;
 196  }
 197  backsql_free_db_conn(bd,&tmp);
 198  if (!si->schema_loaded)
 199  {
 200   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): test failed, schema map not loaded - exiting\n",0,0,0);
 201   return 1;
 202  }
 203  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_open(): test succeeded, schema map loaded\n",0,0,0);
 204  return 0;
 205 }
 206
 207 int backsql_db_close(BackendDB *bd)
 208 {
 209  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_close()\n",0,0,0);
 210  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_close()\n",0,0,0);
 211  return 0;
 212 }
 213
 214 #endif /* SLAPD_SQL */