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