Merge pull request #7 from zerglingno1/master

Add case commit, rollback and correct exception throw
craftzdog · Jul 17, 2017 · b6692e2 · b6692e2
2 parents 6cc2635 + 3142683
commit b6692e2
Showing 1 changed file with 22 additions and 2 deletions.
diff --git a/windows/RNSqlite2Module.cs b/windows/RNSqlite2Module.cs
@@ -136,6 +136,16 @@ private static bool isEnd(String str)
             return str.TrimStart().StartsWith("end", StringComparison.OrdinalIgnoreCase);
         }
 
+        private static bool isCommit(String str)
+        {
+            return str.TrimStart().StartsWith("commit", StringComparison.OrdinalIgnoreCase);
+        }
+
+        private static bool isRollback(String str)
+        {
+            return str.TrimStart().StartsWith("rollback", StringComparison.OrdinalIgnoreCase);
+        }
+
         [ReactMethod]
         public void exec(string dbName, JArray queries, bool readOnly, IPromise promise)
         {
@@ -171,7 +181,7 @@ public void exec(string dbName, JArray queries, bool readOnly, IPromise promise)
                             TRANSACTIONS[dbName] = db.BeginTransaction();
                             results[i] = EMPTY_RESULT;
                         }
-                        else if (isEnd(sql))
+                        else if (isEnd(sql) || isCommit(sql))
                         {
                             if (TRANSACTIONS[dbName] != null)
                             {
@@ -181,6 +191,16 @@ public void exec(string dbName, JArray queries, bool readOnly, IPromise promise)
                             }
                             results[i] = EMPTY_RESULT;
                         }
+                        else if (isRollback(sql))
+                        {
+                            if (TRANSACTIONS[dbName] != null)
+                            {
+                                TRANSACTIONS[dbName].Rollback();
+                                TRANSACTIONS[dbName].Dispose();
+                                TRANSACTIONS[dbName] = null;
+                            }
+                            results[i] = EMPTY_RESULT;
+                        }
                         else
                         { // update/insert/delete
                             if (readOnly)
@@ -407,7 +427,7 @@ private static List<Object> convertPluginResultToArray(SQLitePLuginResult result
             catch (Exception e)
             {
                 debug("insert or update or delete error", e.Message);
-                return EMPTY_RESULT;
+                throw new Exception(e.Message);
             }
             finally
             {