1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
|
/* $Id: mod_log_sql_mysql.c,v 1.4 2004/03/05 00:30:58 urkle Exp $ */
#include "mysql.h"
#include "mysqld_error.h"
#if defined(WITH_APACHE20)
# include "apache20.h"
#elif defined(WITH_APACHE13)
# include "apache13.h"
#else
# error Unsupported Apache version
#endif
#ifdef HAVE_CONFIG_H
/* Undefine these to prevent conflicts between Apache ap_config_auto.h and
* my config.h. Only really needed for Apache < 2.0.48, but it can't hurt.
*/
#undef PACKAGE_BUGREPORT
#undef PACKAGE_NAME
#undef PACKAGE_STRING
#undef PACKAGE_TARNAME
#undef PACKAGE_VERSION
#include "config.h"
#endif
#include "mod_log_sql.h"
/* The enduser won't modify these */
#define MYSQL_ERROR(mysql) ((mysql)?(mysql_error(mysql)):"MySQL server has gone away")
/* Connect to the MYSQL database */
static logsql_opendb_ret log_sql_mysql_connect(server_rec *s, logsql_dbconnection *db)
{
const char *host = apr_table_get(db->parms,"hostname");
const char *user = apr_table_get(db->parms,"username");
const char *passwd = apr_table_get(db->parms,"password");
const char *database = apr_table_get(db->parms,"database");
const char *s_tcpport = apr_table_get(db->parms,"port");
unsigned int tcpport = (s_tcpport)?atoi(s_tcpport):3306;
const char *socketfile = apr_table_get(db->parms,"socketfile");
MYSQL *dblink = db->handle;
dblink = mysql_init(dblink);
db->handle = (void *)dblink;
if (!socketfile) {
socketfile = "/var/lib/mysql/mysql.sock";
}
if (mysql_real_connect(dblink, host, user, passwd, database, tcpport,
socketfile, 0)) {
log_error(APLOG_MARK,APLOG_DEBUG,0, s,"HOST: '%s' PORT: '%d' DB: '%s' USER: '%s' SOCKET: '%s'",
host, tcpport, database, user, socketfile);
return LOGSQL_OPENDB_SUCCESS;
} else {
log_error(APLOG_MARK,APLOG_DEBUG,0, s,"mod_log_sql: database connection error: %s",
MYSQL_ERROR(dblink));
log_error(APLOG_MARK,APLOG_DEBUG, 0, s,"HOST: '%s' PORT: '%d' DB: '%s' USER: '%s' SOCKET: '%s'",
host, tcpport, database, user, socketfile);
return LOGSQL_OPENDB_FAIL;
}
}
/* Close the DB link */
static void log_sql_mysql_close(logsql_dbconnection *db)
{
mysql_close((MYSQL *)db->handle);
}
/* Routine to escape the 'dangerous' characters that would otherwise
* corrupt the INSERT string: ', \, and "
*/
static const char *log_sql_mysql_escape(const char *from_str, apr_pool_t *p,
logsql_dbconnection *db)
{
if (!from_str)
return NULL;
else {
char *to_str;
unsigned long length = strlen(from_str);
unsigned long retval;
/* Pre-allocate a new string that could hold twice the original, which would only
* happen if the whole original string was 'dangerous' characters.
*/
to_str = (char *) apr_palloc(p, length * 2 + 1);
if (!to_str) {
return from_str;
}
if (!db->connected) {
/* Well, I would have liked to use the current database charset. mysql is
* unavailable, however, so I fall back to the slightly less respectful
* mysql_escape_string() function that uses the default charset.
*/
retval = mysql_escape_string(to_str, from_str, length);
} else {
/* MySQL is available, so I'll go ahead and respect the current charset when
* I perform the escape.
*/
retval = mysql_real_escape_string((MYSQL *)db->handle, to_str, from_str, length);
}
if (retval)
return to_str;
else
return from_str;
}
}
/* Run a mysql insert query and return a categorized error or success */
static logsql_query_ret log_sql_mysql_query(request_rec *r,logsql_dbconnection *db,
const char *query)
{
int retval;
void (*handler) (int);
unsigned int real_error = 0;
/*const char *real_error_str = NULL;*/
MYSQL *dblink = (MYSQL *)db->handle;
if (!dblink) {
return LOGSQL_QUERY_NOLINK;
}
/* A failed mysql_query() may send a SIGPIPE, so we ignore that signal momentarily. */
handler = signal(SIGPIPE, SIG_IGN);
/* Run the query */
if (!(retval = mysql_query(dblink, query))) {
signal(SIGPIPE, handler);
return LOGSQL_QUERY_SUCCESS;
}
/* Check to see if the error is "nonexistent table" */
real_error = mysql_errno(dblink);
if (real_error == ER_NO_SUCH_TABLE) {
log_error(APLOG_MARK,APLOG_ERR,0, r->server,"table does not exist, preserving query");
/* Restore SIGPIPE to its original handler function */
signal(SIGPIPE, handler);
return LOGSQL_QUERY_NOTABLE;
}
/* Restore SIGPIPE to its original handler function */
signal(SIGPIPE, handler);
return LOGSQL_QUERY_FAIL;
}
/* Create table table_name of type table_type. */
static logsql_table_ret log_sql_mysql_create(request_rec *r, logsql_dbconnection *db,
logsql_tabletype table_type, const char *table_name)
{
int retval;
const char *tabletype = apr_table_get(db->parms,"tabletype");
void (*handler) (int);
char *type_suffix = NULL;
char *create_prefix = "create table if not exists `";
char *create_suffix = NULL;
char *create_sql;
MYSQL *dblink = (MYSQL *)db->handle;
/* if (!global_config.createtables) {
return APR_SUCCESS;
}*/
switch (table_type) {
case LOGSQL_TABLE_ACCESS:
create_suffix =
"` (id char(19),\
agent varchar(255),\
bytes_sent int unsigned,\
child_pid smallint unsigned,\
cookie varchar(255),\
machine_id varchar(25),\
request_file varchar(255),\
referer varchar(255),\
remote_host varchar(50),\
remote_logname varchar(50),\
remote_user varchar(50),\
request_duration smallint unsigned,\
request_line varchar(255),\
request_method varchar(10),\
request_protocol varchar(10),\
request_time char(28),\
request_uri varchar(255),\
request_args varchar(255),\
server_port smallint unsigned,\
ssl_cipher varchar(25),\
ssl_keysize smallint unsigned,\
ssl_maxkeysize smallint unsigned,\
status smallint unsigned,\
time_stamp int unsigned,\
virtual_host varchar(255))";
break;
case LOGSQL_TABLE_COOKIES:
case LOGSQL_TABLE_HEADERSIN:
case LOGSQL_TABLE_HEADERSOUT:
case LOGSQL_TABLE_NOTES:
create_suffix =
"` (id char(19),\
item varchar(80),\
val varchar(80))";
break;
}
if (tabletype) {
type_suffix = apr_pstrcat(r->pool, " TYPE=",
tabletype, NULL);
}
/* Find memory long enough to hold the whole CREATE string + \0 */
create_sql = apr_pstrcat(r->pool, create_prefix, table_name, create_suffix,
type_suffix, NULL);
log_error(APLOG_MARK,APLOG_DEBUG,0, r->server,"create string: %s", create_sql);
if (!dblink) {
return LOGSQL_QUERY_NOLINK;
}
/* A failed mysql_query() may send a SIGPIPE, so we ignore that signal momentarily. */
handler = signal(SIGPIPE, SIG_IGN);
/* Run the create query */
if ((retval = mysql_query(dblink, create_sql))) {
log_error(APLOG_MARK,APLOG_ERR,0, r->server,"failed to create table: %s",
table_name);
signal(SIGPIPE, handler);
return LOGSQL_TABLE_FAIL;
}
signal(SIGPIPE, handler);
return LOGSQL_TABLE_SUCCESS;
}
static char *supported_drivers[] = {"mysql",NULL};
static logsql_dbdriver mysql_driver = {
supported_drivers,
log_sql_mysql_connect, /* open DB connection */
log_sql_mysql_close, /* close DB connection */
log_sql_mysql_escape, /* escape query */
log_sql_mysql_query, /* insert query */
log_sql_mysql_create /* create table */
};
LOGSQL_REGISTER(mysql) {
log_sql_register_driver(p,&mysql_driver);
LOGSQL_REGISTER_RETURN;
}
|
