]> git.sur5r.net Git - openldap/blob - servers/slapd/back-sql/init.c
6e8a9db9affae490cf8c7dbaeda35731f5fb37e3
[openldap] / servers / slapd / back-sql / init.c
1 /*
2  *       Copyright 1999, Dmitry Kovalev (zmit@mail.ru), 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  free(si->subtree_cond);
120  free(si->oc_query);
121  free(si->at_query);
122  free(si->insentry_query);
123  free(si->delentry_query);
124  free(si);
125  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_destroy()\n",0,0,0);
126  return 0;
127 }
128
129 int backsql_db_open (BackendDB *bd)
130 {
131  backsql_info *si=(backsql_info*)bd->be_private;
132  Connection tmp;
133  SQLHDBC dbh;
134
135  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_open(): testing RDBMS connection\n",0,0,0);
136  if (si->dbname==NULL)
137  {
138   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): datasource name not specified (use dbname directive in slapd.conf)\n",0,0,0);
139   return 1;
140  }
141  if (si->dbuser==NULL)
142  {
143   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): user name not specified (use dbuser directive in slapd.conf)\n",0,0,0);
144   return 1;
145  }
146  if (si->subtree_cond==NULL)
147  {
148   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): subtree search SQL condition not specified (use subtree_cond directive in slapd.conf)\n",0,0,0);
149   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' as default\n",backsql_def_subtree_cond,0,0);
150   si->subtree_cond=strdup(backsql_def_subtree_cond);
151  }
152  if (si->oc_query==NULL)
153  {
154   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): objectclass mapping SQL statement not specified (use oc_query directive in slapd.conf)\n",0,0,0);
155   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_oc_query,0,0);
156   si->oc_query=strdup(backsql_def_oc_query);
157  }
158  if (si->at_query==NULL)
159  {
160   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): attribute mapping SQL statement not specified (use at_query directive in slapd.conf)\n",0,0,0);
161   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_at_query,0,0);
162   si->at_query=strdup(backsql_def_at_query);
163  }
164  if (si->insentry_query==NULL)
165  {
166   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): entry insertion SQL statement not specified (use insentry_query directive in slapd.conf)\n",0,0,0);
167   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_insentry_query,0,0);
168   si->insentry_query=strdup(backsql_def_insentry_query);
169  }
170  if (si->delentry_query==NULL)
171  {
172   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): entry deletion SQL statement not specified (use delentry_query directive in slapd.conf)\n",0,0,0);
173   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): setting '%s' by default\n",backsql_def_delentry_query,0,0);
174   si->delentry_query=strdup(backsql_def_delentry_query);
175  }
176  tmp.c_connid=-1;
177  dbh=backsql_get_db_conn(bd,&tmp);
178  if (!dbh)
179  {
180   Debug(LDAP_DEBUG_TRACE,"backsql_db_open(): connection failed, exiting\n",0,0,0);
181   return 1;
182  }
183  backsql_free_db_conn(bd,&tmp);
184  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_open(): test succeeded, schema map loaded\n",0,0,0);
185  return 0;
186 }
187
188 int backsql_db_close(BackendDB *bd)
189 {
190  Debug(LDAP_DEBUG_TRACE,"==>backsql_db_close()\n",0,0,0);
191  Debug(LDAP_DEBUG_TRACE,"<==backsql_db_close()\n",0,0,0);
192  return 0;
193 }
194
195 #endif /* SLAPD_SQL */