Changeset 20087

Timestamp:

09/28/08 11:03:03 (5 years ago)

Author:

tokuhirom

Message:

added transaction support

Location:

lang/cplusplus/llv8call/trunk

Files:

• ext/sqlite3/sqlite3.cc (modified) (3 diffs)
• t/020_ext/06_sqlite.js (modified) (1 diff)

lang/cplusplus/llv8call/trunk/ext/sqlite3/sqlite3.cc

@@ +1 @@
+// based on Python DB API 2.0
+// see also
+//   http://www.python.org/dev/peps/pep-0249/
+//   http://www.python.jp/doc/contrib/peps/pep-0249.txt
+
 #include "sqlite3.h"
 #include <v8.h>
@@ -34 +39 @@
         return str;
     }
+    if ( sqlite3_exec(db, "BEGIN", NULL, NULL, NULL) != SQLITE_OK) {
+        return throw_errmsg(db);
+    }
     args.This()->SetInternalField(0, External::New((void*)db));
     return args.This();
+}
+
+static Handle<Value> _commit(const Arguments& args) {
+    assert_args(args, 0);
+    HandleScope handle_scope;
+    sqlite3 *db = handle<sqlite3>(args, 0);
+    if ( sqlite3_exec(db, "COMMIT", NULL, NULL, NULL) != SQLITE_OK) {
+        return throw_errmsg(db);
+    }
+    if ( sqlite3_exec(db, "BEGIN", NULL, NULL, NULL) != SQLITE_OK) {
+        return throw_errmsg(db);
+    }
+    return Undefined();
+}
+
+static Handle<Value> _rollback(const Arguments& args) {
+    assert_args(args, 0);
+    HandleScope handle_scope;
+    sqlite3 *db = handle<sqlite3>(args, 0);
+    if ( sqlite3_exec(db, "ROLLBACK", NULL, NULL, NULL) != SQLITE_OK) {
+        return throw_errmsg(db);
+    }
+    return Undefined();
 }
 
@@ -186 +217 @@
     Handle<ObjectTemplate>   ot = ft->InstanceTemplate();
 
-    ot->Set(String::New("Close"), FunctionTemplate::New(_close));
-    ot->Set(String::New("Cursor"), FunctionTemplate::New(_cursor));
+    ot->Set(String::New("Close"),    FunctionTemplate::New(_close));
+    ot->Set(String::New("Commit"),   FunctionTemplate::New(_commit));
+    ot->Set(String::New("Rollback"), FunctionTemplate::New(_rollback));
+    ot->Set(String::New("Cursor"),   FunctionTemplate::New(_cursor));
 
     {

lang/cplusplus/llv8call/trunk/t/020_ext/06_sqlite.js

@@ -29 +29 @@
 db.Exec("INSERT INTO foo (id, name) VALUES (2, 'sato')");
 db.Exec("INSERT INTO foo (id, name) VALUES (3, 'kato')");
+db.Commit();
+db.Exec("INSERT INTO foo (id, name) VALUES (4, 'maesaka')");  // will rollback this
+db.Rollback();
 
 (function (db) {