| 17 |
#include "common.h" |
#include "common.h" |
| 18 |
#include "database.h" |
#include "database.h" |
| 19 |
#include "log.h" |
#include "log.h" |
|
#include <mysql.h> |
|
| 20 |
#include <stdio.h> |
#include <stdio.h> |
| 21 |
|
#include <mysql/mysql.h> |
| 22 |
|
|
| 23 |
// Global declaration for database |
// Global declaration for database |
| 24 |
char DB_host[256]; |
char DB_host[256]; |
| 29 |
|
|
| 30 |
MYSQL *db_open() |
MYSQL *db_open() |
| 31 |
{ |
{ |
| 32 |
MYSQL *db; |
MYSQL *db = NULL; |
| 33 |
char sql[SQL_BUFFER_LEN]; |
char sql[SQL_BUFFER_LEN]; |
| 34 |
|
|
| 35 |
db = mysql_init(NULL); |
db = mysql_init(NULL); |
| 39 |
return NULL; |
return NULL; |
| 40 |
} |
} |
| 41 |
|
|
| 42 |
db = mysql_real_connect(db, DB_host, DB_username, DB_password, DB_database, |
if (mysql_real_connect(db, DB_host, DB_username, DB_password, DB_database, |
| 43 |
0, NULL, 0); |
0, NULL, 0) == NULL) |
|
if (db == NULL) |
|
| 44 |
{ |
{ |
| 45 |
log_error("mysql_connect() failed\n"); |
log_error("mysql_real_connect() error: %s\n", mysql_error(db)); |
| 46 |
|
mysql_close(db); |
| 47 |
return NULL; |
return NULL; |
| 48 |
} |
} |
| 49 |
|
|
| 50 |
if (mysql_set_character_set(db, "gb2312") != 0) |
if (mysql_set_character_set(db, "gb2312") != 0) |
| 51 |
{ |
{ |
| 52 |
log_error("Set character set failed\n"); |
log_error("Set character set error: %s\n", mysql_error(db)); |
| 53 |
|
mysql_close(db); |
| 54 |
return NULL; |
return NULL; |
| 55 |
} |
} |
| 56 |
|
|
| 57 |
snprintf(sql, sizeof(sql), |
snprintf(sql, sizeof(sql), |
| 58 |
"SET time_zone = '%s'", |
"SET time_zone = '%s'", |
| 59 |
DB_timezone); |
DB_timezone); |
| 60 |
|
|
| 61 |
if (mysql_query(db, sql) != 0) |
if (mysql_query(db, sql) != 0) |
| 62 |
{ |
{ |
| 63 |
log_error("Set timezone error: %s\n", mysql_error(db)); |
log_error("Set timezone error: %s\n", mysql_error(db)); |
| 64 |
|
mysql_close(db); |
| 65 |
return NULL; |
return NULL; |
| 66 |
} |
} |
| 67 |
|
|