2 * sql_mysql.c SQL Module
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
20 * Copyright 2000 The FreeRADIUS server project
21 * Copyright 2000 Mike Machado <mike@innercite.com>
22 * Copyright 2000 Alan DeKok <aland@ox.org>
30 #include <mysql/errmsg.h>
34 #include <mysql/mysql.h>
37 typedef struct rlm_sql_mysql_sock {
44 /*************************************************************************
46 * Function: sql_create_socket
48 * Purpose: Establish connection to the db
50 *************************************************************************/
51 static int sql_init_socket(SQLSOCK *sqlsocket, SQL_CONFIG *config) {
53 rlm_sql_mysql_sock *mysql_sock;
55 sqlsocket->conn = (rlm_sql_mysql_sock *)rad_malloc(sizeof(rlm_sql_mysql_sock));
57 mysql_sock = sqlsocket->conn;
59 radlog(L_INFO, "rlm_sql: Starting connect to MySQL server for #%d",
62 mysql_init(&(mysql_sock->conn));
63 if (!(mysql_sock->sock = mysql_real_connect(&(mysql_sock->conn), config->sql_server, config->sql_login, config->sql_password,
64 config->sql_db, 0, NULL, CLIENT_FOUND_ROWS))) {
65 radlog(L_ERR, "rlm_sql: Couldn't connect socket to MySQL server %s@%s:%s", config->sql_login, config->sql_server, config->sql_db);
66 radlog(L_ERR, "rlm_sql: Mysql error '%s'", mysql_error(&mysql_sock->conn));
67 mysql_sock->sock = NULL;
76 /*************************************************************************
78 * Function: sql_destroy_socket
80 * Purpose: Free socket and any private connection data
82 *************************************************************************/
83 static int sql_destroy_socket(SQLSOCK *sqlsocket, SQL_CONFIG *config) {
85 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
94 /*************************************************************************
98 * Purpose: Issue a query to the database
100 *************************************************************************/
101 static int sql_query(SQLSOCK * sqlsocket, SQL_CONFIG *config, char *querystr) {
103 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
105 if (config->sqltrace)
106 radlog(L_DBG,"query: %s", querystr);
107 if (mysql_sock->sock == NULL) {
108 radlog(L_ERR, "Socket not connected");
112 mysql_query(mysql_sock->sock, querystr);
113 return sql_check_error(mysql_errno(mysql_sock->sock));
117 /*************************************************************************
119 * Function: sql_select_query
121 * Purpose: Issue a select query to the database
123 *************************************************************************/
124 static int sql_select_query(SQLSOCK *sqlsocket, SQL_CONFIG *config, char *querystr) {
128 ret = sql_query(sqlsocket, config, querystr);
131 ret = sql_store_result(sqlsocket, config);
136 /* Why? Per http://www.mysql.com/doc/n/o/node_591.html,
137 * this cannot return an error. Perhaps just to complain if no
140 sql_num_fields(sqlsocket, config);
146 /*************************************************************************
148 * Function: sql_store_result
150 * Purpose: database specific store_result function. Returns a result
153 *************************************************************************/
154 static int sql_store_result(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
156 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
158 if (mysql_sock->sock == NULL) {
159 radlog(L_ERR, "Socket not connected");
162 if (!(mysql_sock->result = mysql_store_result(mysql_sock->sock))) {
163 radlog(L_ERR, "MYSQL Error: Cannot get result");
164 radlog(L_ERR, "MYSQL Error: %s", mysql_error(mysql_sock->sock));
165 return sql_check_error(mysql_errno(mysql_sock->sock));
171 /*************************************************************************
173 * Function: sql_num_fields
175 * Purpose: database specific num_fields function. Returns number
176 * of columns from query
178 *************************************************************************/
179 static int sql_num_fields(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
183 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
185 #if MYSQL_VERSION_ID >= 32224
186 if (!(num = mysql_field_count(mysql_sock->sock))) {
188 if (!(num = mysql_num_fields(mysql_sock->sock))) {
190 radlog(L_ERR, "MYSQL Error: No Fields");
191 radlog(L_ERR, "MYSQL error: %s", mysql_error(mysql_sock->sock));
197 /*************************************************************************
199 * Function: sql_num_rows
201 * Purpose: database specific num_rows. Returns number of rows in
204 *************************************************************************/
205 static int sql_num_rows(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
207 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
209 if(mysql_sock->result)
210 return mysql_num_rows(mysql_sock->result);
216 /*************************************************************************
218 * Function: sql_fetch_row
220 * Purpose: database specific fetch_row. Returns a SQL_ROW struct
221 * with all the data for the query in 'sqlsocket->row'. Returns
222 * 0 on success, -1 on failure, SQL_DOWN if database is down.
224 *************************************************************************/
225 static int sql_fetch_row(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
227 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
229 sqlsocket->row = mysql_fetch_row(mysql_sock->result);
231 if (sqlsocket->row == NULL) {
232 return sql_check_error(mysql_errno(mysql_sock->sock));
238 /*************************************************************************
240 * Function: sql_check_error
242 * Purpose: check the error to see if the server is down
244 *************************************************************************/
245 static int sql_check_error(int error) {
247 case CR_SERVER_GONE_ERROR:
250 radlog(L_DBG, "MYSQL check_error: %d, returning SQL_DOWN", error);
256 case CR_OUT_OF_MEMORY:
257 case CR_COMMANDS_OUT_OF_SYNC:
258 case CR_UNKNOWN_ERROR:
260 radlog(L_DBG, "MYSQL check_error: %d received", error);
268 /*************************************************************************
270 * Function: sql_free_result
272 * Purpose: database specific free_result. Frees memory allocated
275 *************************************************************************/
276 static int sql_free_result(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
278 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
280 if (mysql_sock->result) {
281 mysql_free_result(mysql_sock->result);
289 /*************************************************************************
291 * Function: sql_error
293 * Purpose: database specific error. Returns error associated with
296 *************************************************************************/
297 static char *sql_error(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
299 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
301 return mysql_error(mysql_sock->sock);
305 /*************************************************************************
307 * Function: sql_close
309 * Purpose: database specific close. Closes an open database
312 *************************************************************************/
313 static int sql_close(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
315 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
317 mysql_close(mysql_sock->sock);
318 mysql_sock->sock = NULL;
324 /*************************************************************************
326 * Function: sql_finish_query
328 * Purpose: End the query, such as freeing memory
330 *************************************************************************/
331 static int sql_finish_query(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
338 /*************************************************************************
340 * Function: sql_finish_select_query
342 * Purpose: End the select query, such as freeing memory or result
344 *************************************************************************/
345 static int sql_finish_select_query(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
347 sql_free_result(sqlsocket, config);
353 /*************************************************************************
355 * Function: sql_affected_rows
357 * Purpose: End the select query, such as freeing memory or result
359 *************************************************************************/
360 static int sql_affected_rows(SQLSOCK * sqlsocket, SQL_CONFIG *config) {
362 rlm_sql_mysql_sock *mysql_sock = sqlsocket->conn;
364 return mysql_affected_rows(mysql_sock->sock);
368 /* Exported to rlm_sql */
369 rlm_sql_module_t rlm_sql_mysql = {
383 sql_finish_select_query,