Commit 989f5a6b by Orlando Vazquez

small perf tweaks

parent e631a8e4
...@@ -81,8 +81,8 @@ public: ...@@ -81,8 +81,8 @@ public:
NODE_SET_PROTOTYPE_METHOD(t, "open", Open); NODE_SET_PROTOTYPE_METHOD(t, "open", Open);
NODE_SET_PROTOTYPE_METHOD(t, "close", Close); NODE_SET_PROTOTYPE_METHOD(t, "close", Close);
NODE_SET_PROTOTYPE_METHOD(t, "changes", Changes); // NODE_SET_PROTOTYPE_METHOD(t, "changes", Changes);
NODE_SET_PROTOTYPE_METHOD(t, "lastInsertRowid", LastInsertRowid); // NODE_SET_PROTOTYPE_METHOD(t, "lastInsertRowid", LastInsertRowid);
NODE_SET_PROTOTYPE_METHOD(t, "prepare", Prepare); NODE_SET_PROTOTYPE_METHOD(t, "prepare", Prepare);
target->Set(v8::String::NewSymbol("Database"), t->GetFunction()); target->Set(v8::String::NewSymbol("Database"), t->GetFunction());
...@@ -420,10 +420,10 @@ protected: ...@@ -420,10 +420,10 @@ protected:
t->InstanceTemplate()->SetInternalFieldCount(1); t->InstanceTemplate()->SetInternalFieldCount(1);
NODE_SET_PROTOTYPE_METHOD(t, "bind", Bind); NODE_SET_PROTOTYPE_METHOD(t, "bind", Bind);
NODE_SET_PROTOTYPE_METHOD(t, "clearBindings", ClearBindings); // NODE_SET_PROTOTYPE_METHOD(t, "clearBindings", ClearBindings);
NODE_SET_PROTOTYPE_METHOD(t, "finalize", Finalize); NODE_SET_PROTOTYPE_METHOD(t, "finalize", Finalize);
NODE_SET_PROTOTYPE_METHOD(t, "bindParameterCount", BindParameterCount); // NODE_SET_PROTOTYPE_METHOD(t, "bindParameterCount", BindParameterCount);
NODE_SET_PROTOTYPE_METHOD(t, "reset", Reset); // NODE_SET_PROTOTYPE_METHOD(t, "reset", Reset);
NODE_SET_PROTOTYPE_METHOD(t, "step", Step); NODE_SET_PROTOTYPE_METHOD(t, "step", Step);
//target->Set(v8::String::NewSymbol("SQLStatement"), t->GetFunction()); //target->Set(v8::String::NewSymbol("SQLStatement"), t->GetFunction());
...@@ -434,14 +434,14 @@ protected: ...@@ -434,14 +434,14 @@ protected:
int I = 0; int I = 0;
REQ_EXT_ARG(0, stmt); REQ_EXT_ARG(0, stmt);
(new Statement((sqlite3_stmt*)stmt->Value()))->Wrap(args.This()); (new Statement((sqlite3_stmt*)stmt->Value()))->Wrap(args.This());
return args.This(); return args.This();
} }
protected: protected:
Statement(sqlite3_stmt* stmt) : stmt_(stmt) {} Statement(sqlite3_stmt* stmt) : stmt_(stmt) {}
~Statement() { if (stmt_) sqlite3_finalize(stmt_); } ~Statement() { if (stmt_) { sqlite3_finalize(stmt_); } }
sqlite3_stmt* stmt_; sqlite3_stmt* stmt_;
operator sqlite3_stmt* () const { return stmt_; } operator sqlite3_stmt* () const { return stmt_; }
...@@ -804,9 +804,12 @@ protected: ...@@ -804,9 +804,12 @@ protected:
} }
step_req->cb.Dispose(); step_req->cb.Dispose();
free(step_req->column_data);
free(step_req->column_types); if (step_req->column_count) {
free(step_req->column_names); free(step_req->column_data);
free(step_req->column_types);
free(step_req->column_names);
}
free(step_req); free(step_req);
...@@ -823,13 +826,14 @@ protected: ...@@ -823,13 +826,14 @@ protected:
if (rc == SQLITE_ROW) { if (rc == SQLITE_ROW) {
// would be nice to cache the column names and type data somewhere // would be nice to cache the column names and type data somewhere
step_req->column_count = sqlite3_column_count(stmt); if (step_req->column_count = sqlite3_column_count(stmt)) {
step_req->column_types = step_req->column_types =
(int *) calloc(step_req->column_count, sizeof(int)); (int *) calloc(step_req->column_count, sizeof(int));
step_req->column_data = step_req->column_data =
(void **) calloc(step_req->column_count, sizeof(void *)); (void **) calloc(step_req->column_count, sizeof(void *));
step_req->column_names = step_req->column_names =
(char **) calloc(step_req->column_count, sizeof(char *)); (char **) calloc(step_req->column_count, sizeof(char *));
}
for (int i = 0; i < step_req->column_count; i++) { for (int i = 0; i < step_req->column_count; i++) {
int type = step_req->column_types[i] = sqlite3_column_type(stmt, i); int type = step_req->column_types[i] = sqlite3_column_type(stmt, i);
......
...@@ -28,7 +28,7 @@ function writeTest(db, callback) { ...@@ -28,7 +28,7 @@ function writeTest(db, callback) {
function innerFunction () { function innerFunction () {
db.query("INSERT INTO t1 VALUES (1)", function (row) { db.query("INSERT INTO t1 VALUES (1)", function (row) {
if (!i-- && !row) { if (!i--) {
// end of results // end of results
var dt = ((new Date)-t0)/1000; var dt = ((new Date)-t0)/1000;
puts("**** " + count + " insertions in " + dt + "s (" + (count/dt) + "/s)"); puts("**** " + count + " insertions in " + dt + "s (" + (count/dt) + "/s)");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment