57 |
} |
} |
58 |
|
|
59 |
int |
int |
60 |
disp_sql_reconnect(int type, int conn_type, struct sql_connection *conn) |
disp_sql_reconnect(int interface, int conn_type, struct sql_connection *conn) |
61 |
{ |
{ |
62 |
if (!conn) |
if (!conn) |
63 |
return -1; |
return -1; |
64 |
if (conn->connected) |
if (conn->connected) |
65 |
disp_sql_entry(type)->disconnect(conn, 0); |
disp_sql_entry(conn->interface)->disconnect(conn, 0); |
66 |
return disp_sql_entry(type)->reconnect(conn_type, conn); |
conn->interface = interface; |
67 |
|
return disp_sql_entry(conn->interface)->reconnect(conn_type, conn); |
68 |
} |
} |
69 |
|
|
70 |
void |
void |
71 |
disp_sql_drop(int type, struct sql_connection *conn) |
disp_sql_drop(struct sql_connection *conn) |
72 |
{ |
{ |
73 |
if (conn && conn->connected) |
if (conn && conn->connected) |
74 |
disp_sql_entry(type)->disconnect(conn, 1); |
disp_sql_entry(conn->interface)->disconnect(conn, 1); |
75 |
} |
} |
76 |
|
|
77 |
void |
void |
78 |
disp_sql_disconnect(int type, struct sql_connection *conn) |
disp_sql_disconnect(struct sql_connection *conn) |
79 |
{ |
{ |
80 |
if (conn && conn->connected) |
if (conn && conn->connected) |
81 |
disp_sql_entry(type)->disconnect(conn, 0); |
disp_sql_entry(conn->interface)->disconnect(conn, 0); |
82 |
} |
} |
83 |
|
|
84 |
int |
int |
85 |
disp_sql_query(int type, struct sql_connection *conn, |
disp_sql_query(struct sql_connection *conn, char *query, int *report_cnt) |
|
char *query, int *report_cnt) |
|
86 |
{ |
{ |
87 |
int rc; |
int rc; |
88 |
|
|
89 |
if (!conn) |
if (!conn) |
90 |
return -1; |
return -1; |
91 |
rc = disp_sql_entry(type)->query(conn, query, report_cnt); |
rc = disp_sql_entry(conn->interface)->query(conn, query, report_cnt); |
92 |
if (rc) |
if (rc) |
93 |
radlog(L_ERR, "%s: %s", _("Failed query was"), query); |
radlog(L_ERR, "%s: %s", _("Failed query was"), query); |
94 |
return rc; |
return rc; |
95 |
} |
} |
96 |
|
|
97 |
char * |
char * |
98 |
disp_sql_getpwd(int type, struct sql_connection *conn, char *query) |
disp_sql_getpwd(struct sql_connection *conn, char *query) |
99 |
{ |
{ |
100 |
if (!conn) |
if (!conn) |
101 |
return NULL; |
return NULL; |
102 |
return disp_sql_entry(type)->getpwd(conn, query); |
return disp_sql_entry(conn->interface)->getpwd(conn, query); |
103 |
} |
} |
104 |
|
|
105 |
void * |
void * |
106 |
disp_sql_exec(int type, struct sql_connection *conn, char *query) |
disp_sql_exec(struct sql_connection *conn, char *query) |
107 |
{ |
{ |
108 |
return disp_sql_entry(type)->exec_query(conn, query); |
return disp_sql_entry(conn->interface)->exec_query(conn, query); |
109 |
} |
} |
110 |
|
|
111 |
char * |
char * |
112 |
disp_sql_column(int type, void *data, int ncol) |
disp_sql_column(struct sql_connection *conn, void *data, size_t ncol) |
113 |
{ |
{ |
114 |
return disp_sql_entry(type)->column(data, ncol); |
return disp_sql_entry(conn->interface)->column(data, ncol); |
115 |
} |
} |
116 |
|
|
117 |
int |
int |
118 |
disp_sql_next_tuple(int type, struct sql_connection *conn, void *data) |
disp_sql_next_tuple(struct sql_connection *conn, void *data) |
119 |
{ |
{ |
120 |
if (!conn) |
if (!conn) |
121 |
return -1; |
return -1; |
122 |
return disp_sql_entry(type)->next_tuple(conn, data); |
return disp_sql_entry(conn->interface)->next_tuple(conn, data); |
123 |
} |
} |
124 |
|
|
125 |
/*ARGSUSED*/ |
/*ARGSUSED*/ |
126 |
void |
void |
127 |
disp_sql_free(int type, struct sql_connection *conn, void *data) |
disp_sql_free(struct sql_connection *conn, void *data) |
128 |
{ |
{ |
129 |
if (conn) |
if (conn) |
130 |
disp_sql_entry(type)->free(conn, data); |
disp_sql_entry(conn->interface)->free(conn, data); |
131 |
} |
} |
132 |
|
|
133 |
|
int |
134 |
|
disp_sql_num_tuples(struct sql_connection *conn, void *data, size_t *np) |
135 |
|
{ |
136 |
|
if (conn) |
137 |
|
return disp_sql_entry(conn->interface)->n_tuples(conn, |
138 |
|
data, np); |
139 |
|
return -1; |
140 |
|
} |
141 |
|
|
142 |
|
int |
143 |
|
disp_sql_num_columns(struct sql_connection *conn, void *data, size_t *np) |
144 |
|
{ |
145 |
|
if (conn) |
146 |
|
return disp_sql_entry(conn->interface)->n_columns(conn, |
147 |
|
data, np); |
148 |
|
return 0; |
149 |
|
} |
150 |
|
|
151 |
|
|