Remove pthread.h from source. We should be using asterisk/lock.h everywhere instead...
[asterisk/asterisk.git] / res / res_config_odbc.c
1 /*
2  * Asterisk -- A telephony toolkit for Linux.
3  *
4  * Copyright (C) 1999, Mark Spencer
5  *
6  * Mark Spencer <markster@linux-support.net>
7  *
8  * res_config_odbc.c <odbc+odbc plugin for portable configuration engine >
9  * Copyright (C) 2004 Anthony Minessale II <anthmct@yahoo.com>
10  */
11
12
13 #include <asterisk/file.h>
14 #include <asterisk/logger.h>
15 #include <asterisk/channel.h>
16 #include <asterisk/pbx.h>
17 #include <asterisk/config.h>
18 #include <asterisk/config_pvt.h>
19 #include <asterisk/module.h>
20 #include <asterisk/lock.h>
21 #include <stdlib.h>
22 #include <unistd.h>
23 #include <string.h>
24 #include <asterisk/res_odbc.h>
25
26
27
28 static char *tdesc = "Odbc Configuration";
29 static struct ast_config_reg reg1;
30
31
32 STANDARD_LOCAL_USER;
33
34 LOCAL_USER_DECL;
35
36
37 static struct ast_config *config_odbc(char *file, struct ast_config *new_config_s,struct ast_category **new_cat_p,struct ast_variable **new_v_p,int recur
38 #ifdef PRESERVE_COMMENTS
39                                       ,struct ast_comment_struct *acs
40 #endif
41
42                                       ) {
43
44
45
46
47   struct ast_config *config,*new;
48   struct ast_variable *v,*cur_v,*new_v;
49   struct ast_category *cur_cat,*new_cat;
50   char table[128];
51   char connection[128];
52   int configured=0, res=0;
53   odbc_obj *obj;
54   SQLINTEGER err,commented,cat_metric,var_metric;
55   SQLBIGINT id;
56   char sql[255],filename[128],category[128],var_name[128],var_val[128];
57   SQLSMALLINT rowcount;
58   SQLHSTMT stmt;
59   char last[80];
60   int cat_started=0;
61   int var_started=0;
62
63
64   if(new_config_s) {
65     new = new_config_s;
66     cat_started++;
67   }
68   else 
69     new = ast_new_config();
70
71   last[0] = '\0';
72
73   if(!file || !strcmp(file,"res_config_odbc.conf"))
74     return NULL; // cant configure myself with myself !
75
76   config = ast_load("res_config_odbc.conf");
77
78   if(config) {
79     for(v = ast_variable_browse(config,"settings");v;v=v->next) {
80       if(!strcmp(v->name,"table")) {
81         strncpy(table,v->value,sizeof(table));
82         configured++;
83       }
84       else if(!strcmp(v->name,"connection")) {
85         strncpy(connection,v->value,sizeof(connection));
86         configured++;
87       }
88     }
89     ast_destroy(config);
90   }
91         
92   if(configured < 2)
93     return NULL;
94         
95   obj = fetch_odbc_obj(connection);
96   if(!obj)
97     return NULL;
98
99
100
101
102
103   res=SQLAllocHandle(SQL_HANDLE_STMT,obj->con, &stmt);
104
105   SQLBindCol(stmt,1,SQL_C_ULONG,&id,sizeof(id),&err);
106   SQLBindCol(stmt,2,SQL_C_ULONG,&cat_metric,sizeof(cat_metric),&err);
107   SQLBindCol(stmt,3,SQL_C_ULONG,&var_metric,sizeof(var_metric),&err);
108   SQLBindCol(stmt,4,SQL_C_ULONG,&commented,sizeof(commented),&err);
109   SQLBindCol(stmt,5,SQL_C_CHAR,&filename,sizeof(filename),&err);
110   SQLBindCol(stmt,6,SQL_C_CHAR,&category,sizeof(category),&err);
111   SQLBindCol(stmt,7,SQL_C_CHAR,&var_name,sizeof(var_name),&err);
112   SQLBindCol(stmt,8,SQL_C_CHAR,&var_val,sizeof(var_val),&err);
113         
114   sprintf(sql,"select * from %s where filename='%s' and commented=0 order by filename,cat_metric,var_metric,id",table,file);
115   res = SQLExecDirect(stmt,sql,SQL_NTS);
116         
117   if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
118     ast_log(LOG_WARNING,"SQL select error!\n[%s]\n\n",sql);
119     return NULL;
120   }
121         
122   res=SQLNumResultCols(stmt,&rowcount);
123         
124   if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
125     ast_log(LOG_WARNING,"SQL select error!\n[%s]\n\n",sql);
126     return NULL;
127   }
128
129
130   if(rowcount) {
131
132     res=SQLFetch(stmt);
133     cat_started=0;
134
135
136                 
137     cur_cat = *new_cat_p;
138     cur_v = *new_v_p;
139                 
140     if(cur_cat)
141       cat_started=1;
142     if(cur_v)
143       var_started=1;
144
145
146
147     while(res != SQL_NO_DATA) {
148       //ast_log(LOG_NOTICE,"found %s %s %s\n",filename,var_name,var_val);
149       // build the config sql table probably needs to be improved!
150
151       if(!strcmp(var_name,"#include") &&  recur < MAX_INCLUDE_LEVEL) {
152                                 
153         config_odbc(var_val,new,&cur_cat,&cur_v,recur + 1
154 #ifdef PRESERVE_COMMENTS
155                     ,acs
156 #endif
157                     );
158
159       }
160       else {                    
161
162                                 
163
164         if(strcmp(last,category)) {
165           strcpy(last,category);
166           new_cat = (struct ast_category *) ast_new_category(category);
167                                         
168           if(!cat_started) {
169             cat_started++;
170             new->root = new_cat;
171             cur_cat=new->root;
172           }
173           else {
174             cur_cat->next = new_cat;
175             cur_cat = cur_cat->next;
176           }
177           var_started=0;
178                                         
179         }
180
181         new_v = ast_new_variable(var_name,var_val);
182                                 
183                                 
184         if(!var_started) {
185           var_started++;
186           cur_cat->root = new_v;
187           cur_v = cur_cat->root;
188         }
189         else {
190           cur_v->next = new_v;
191           cur_v = cur_v->next;
192         }
193       }
194                         
195       // next row 
196       res=SQLFetch(stmt);
197     }
198
199     SQLFreeHandle(SQL_HANDLE_STMT,stmt);
200   }
201   else 
202     ast_log(LOG_NOTICE,"found nothing\n");
203
204         
205
206         
207         
208
209
210         
211   return new;
212         
213 }
214
215
216
217
218 int unload_module(void)
219 {
220     ast_cust_config_deregister(&reg1);
221         ast_log(LOG_NOTICE,"res_config_odbc unloaded.\n");
222         STANDARD_HANGUP_LOCALUSERS;
223         return 0;
224 }
225
226 int load_module(void)
227 {
228
229         memset(&reg1,0,sizeof(struct ast_config_reg));
230         strcpy(reg1.name,"odbc");
231         reg1.func = config_odbc;
232         ast_cust_config_register(&reg1);
233         ast_log(LOG_NOTICE,"res_config_odbc loaded.\n");
234         return 0;
235 }
236
237 char *description(void)
238 {
239   return tdesc;
240 }
241
242 int usecount(void)
243 {
244         /* never unload a config module */
245         return 1;
246 }
247
248 char *key()
249 {
250   return ASTERISK_GPL_KEY;
251 }
252
253