summaryrefslogtreecommitdiffstats
path: root/runtime/lket/b2a/lket_b2a.c
diff options
context:
space:
mode:
Diffstat (limited to 'runtime/lket/b2a/lket_b2a.c')
-rw-r--r--runtime/lket/b2a/lket_b2a.c16
1 files changed, 11 insertions, 5 deletions
diff --git a/runtime/lket/b2a/lket_b2a.c b/runtime/lket/b2a/lket_b2a.c
index eb4c2fc6..a5f4e457 100644
--- a/runtime/lket/b2a/lket_b2a.c
+++ b/runtime/lket/b2a/lket_b2a.c
@@ -654,12 +654,18 @@ void register_evt_desc(FILE *infp, size_t size)
if(!has_table) {
snprintf(sql, 1024, "create table table_desc ( table_name \
varchar(6), table_desc varchar(32))");
+ if(mysql_query(&mysql, sql)) {
+ fprintf(stderr, "Failed exec SQL: \n %s \n, Error: %s\n",
+ sql, mysql_error(&mysql));
+ exit(-1);
+ }
has_table = 1;
- } else {
- snprintf(sql, 1024, "insert into table_desc ( table_name,\
- table_desc) values ( \"%d_%d\", \"%s\")", grpid, hookid,
- evt_body+2);
- }
+ }
+
+ snprintf(sql, 1024, "insert into table_desc ( table_name,\
+ table_desc) values ( \"%d_%d\", \"%s\")", grpid, hookid,
+ evt_body+2);
+
if(mysql_query(&mysql, sql)) {
fprintf(stderr, "Failed exec SQL: \n %s \n, Error: %s\n",
sql, mysql_error(&mysql));