1 files changed, 8 insertions, 3 deletions

diff --git a/util/db.c b/util/db.c
index fee91b2..c2b674e 100644
--- a/util/db.c
+++ b/util/db.c
@@ -91,14 +91,19 @@ static int sql_createstmt(struct ulogd_pluginstance *upi)
 		return -ENOMEM;
 	}
 
-	if (strcasecmp(procedure,"INSERT") == 0) {
-		char buf[ULOGD_MAX_KEYLEN];
-		char *underscore;
+	if (strncasecmp(procedure, "INSERT INTO", strlen("INSERT INTO")) == 0)
+		sprintf(mi->stmt, "%s (", procedure);
 
+	if (strcasecmp(procedure,"INSERT") == 0) {
 		if (mi->schema)
 			sprintf(mi->stmt, "insert into %s.%s (", mi->schema, table);
 		else
 			sprintf(mi->stmt, "insert into %s (", table);
+	}
+
+	if (strncasecmp(procedure,"INSERT", strlen("INSERT")) == 0) {
+		char buf[ULOGD_MAX_KEYLEN];
+		char *underscore;
 		mi->stmt_val = mi->stmt + strlen(mi->stmt);
 
 		for (i = 0; i < upi->input.num_keys; i++) {