From cfaaf54fc8a6ca921382f0bebe4a88999485e984 Mon Sep 17 00:00:00 2001
From: deffpuzzl <deffpuzzl@qq.com>
Date: Wed, 20 Jun 2018 11:21:24 +0800
Subject: [PATCH] fix create scripts

---
 README.MD     | 4 ++++
 include/tvm.h | 2 +-
 src/stvm.c    | 8 +++++---
 3 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/README.MD b/README.MD
index 4fb83ca..c9bac0e 100644
--- a/README.MD
+++ b/README.MD
@@ -116,6 +116,10 @@ STVM也提供一个类型sqlpuls类型简单工具。
 >* 1、新增queue网络同步异步接口
 >* 1、新增将表中长时间无用数据导出备份接口
 
+====***更新日期:20180610***====
+
+>* 1、新增分布式锁
+
 **下本版本：**
 * 1、新增多机资源共享方式。
 * 2、JAVA接口开发
diff --git a/include/tvm.h b/include/tvm.h
index 10e3b91..de1c420 100644
--- a/include/tvm.h
+++ b/include/tvm.h
@@ -34,7 +34,7 @@ typedef long                 CREATE;
 //#pragma pack(4)
 
 #define TVM_VKERNEL                        "1.2.0.0"
-#define TVM_VERSION                        "1.2.4.0"
+#define TVM_VERSION                        "1.2.5.0"
 /*************************************************************************************************
    custom macro
  *************************************************************************************************/
diff --git a/src/stvm.c b/src/stvm.c
index fbe1211..ef9be2a 100644
--- a/src/stvm.c
+++ b/src/stvm.c
@@ -984,14 +984,16 @@ long    lDefineTable(char *pszCreate, char *pszTable)
 
     sfieldreplace(pszCreate, '\t', ' ');
 
-    if(NULL == (p = strcasestr(pszCreate, "create table")) && 
-        NULL == (p = strcasestr(pszCreate, "create queue")))
+    if(NULL == strcasestr(pszCreate, "create table") && 
+        NULL == strcasestr(pszCreate, "create queue"))
     {
         fprintf(stderr, "Lost table syntax\n");
         return RC_FAIL;
     }
 
-    if(NULL != strcasestr(pszCreate, "create queue"))
+    if(NULL != (p = strcasestr(pszCreate, "create table")))
+        bQueue = false; 
+    else if(NULL != (p = strcasestr(pszCreate, "create queue")))
         bQueue = true; 
 
     memset(&sf, 0, sizeof(TblDef));