sqlite

lib/dialects/sqlite/query-generator.js

-var Utils = require("../../utils")
-  , DataTypes = require("../../data-types")
-  , SqlString = require("../../sql-string")
+var Utils       = require("../../utils")
+  , DataTypes   = require("../../data-types")
+  , SqlString   = require("../../sql-string")
+  , Transaction = require("../../transaction")
 
 var MySqlQueryGenerator = Utils._.extend(
   Utils._.clone(require("../abstract/query-generator")),
@@ -396,6 +397,29 @@ module.exports = (function() {
       })
     },
 
+    startTransactionQuery: function(options) {
+      return "BEGIN TRANSACTION;"
+    },
+
+    setAutocommitQuery: function(value) {
+      return "-- SQLite does not support SET autocommit."
+    },
+
+    setIsolationLevelQuery: function(value) {
+      switch (value) {
+        case Transaction.ISOLATION_LEVELS.REPEATABLE_READ:
+          return "-- SQLite is not able to choose the isolation level REPEATABLE READ."
+        case Transaction.ISOLATION_LEVELS.READ_UNCOMMITTED:
+          return "PRAGMA read_uncommitted = ON;"
+        case Transaction.ISOLATION_LEVELS.READ_COMMITTED:
+          return "PRAGMA read_uncommitted = OFF;"
+        case Transaction.ISOLATION_LEVELS.SERIALIZABLE:
+          return "-- SQLite's default isolation level is SERIALIZABLE. Nothing to do."
+        default:
+          throw new Error('Unknown isolation level: ' + value)
+      }
+    },
+
     replaceBooleanDefaults: function(sql) {
       return sql.replace(/DEFAULT '?false'?/g, "DEFAULT 0").replace(/DEFAULT '?true'?/g, "DEFAULT 1")
     },

lib/dialects/sqlite/query.js

@@ -32,13 +32,22 @@ module.exports = (function() {
     var columnTypes = {}
     this.database.serialize(function() {
       var executeSql = function() {
-        self.database[getDatabaseMethod.call(self)](self.sql, function(err, results) {
-          // allow clients to listen to sql to do their own logging or whatnot
-          self.emit('sql', self.sql)
-          this.columnTypes = columnTypes;
-          err ? onFailure.call(self, err) : onSuccess.call(self, results, this)
-        })
-      };
+        if (self.sql.indexOf('-- ') === 0) {
+          // the sql query starts with a comment. don't bother the server with that ...
+          Utils.tick(function() {
+            self.emit('sql', self.sql)
+            console.log('emitting success')
+            self.emit('success', null)
+          })
+        } else {
+          self.database[getDatabaseMethod.call(self)](self.sql, function(err, results) {
+            // allow clients to listen to sql to do their own logging or whatnot
+            self.emit('sql', self.sql)
+            this.columnTypes = columnTypes;
+            err ? onFailure.call(self, err) : onSuccess.call(self, results, this)
+          })
+        }
+      }
 
       if ((getDatabaseMethod.call(self) === 'all') && /select\s.*?\sfrom\s+([^ ;]+)/i.test(self.sql)) {
         var tableName = RegExp.$1;