diff --git a/src/better_sqlite3.cpp b/src/better_sqlite3.cpp index 2e49b1b57..b0a0f8303 100644 --- a/src/better_sqlite3.cpp +++ b/src/better_sqlite3.cpp @@ -869,14 +869,17 @@ void Statement::JS_new (v8::FunctionCallbackInfo const & info) tail += 2; for (char c; (c = *tail); ++tail) { if (c == '*' && tail[1] == '/') { - tail += 1; + tail += 2; break; } } } else if (c == '-' && tail[1] == '-') { tail += 2; for (char c; (c = *tail); ++tail) { - if (c == '\n') break; + if (c == '\n') { + ++tail; + break; + } } } else { sqlite3_finalize(handle); @@ -895,9 +898,9 @@ void Statement::JS_new (v8::FunctionCallbackInfo const & info) info.GetReturnValue().Set(info.This()); } -#line 153 "./src/objects/statement.lzz" +#line 156 "./src/objects/statement.lzz" void Statement::JS_run (v8::FunctionCallbackInfo const & info) -#line 153 "./src/objects/statement.lzz" +#line 156 "./src/objects/statement.lzz" { Statement * stmt = node :: ObjectWrap :: Unwrap < Statement > ( info . This ( ) ) ; ( ( void ) 0 ) ; sqlite3_stmt * handle = stmt -> handle ; Database * db = stmt -> db ; if ( ! db -> GetState ( ) -> open ) return ThrowTypeError ( "The database connection is not open" ) ; if ( db -> GetState ( ) -> busy ) return ThrowTypeError ( "This database connection is busy executing a query" ) ; if ( stmt -> locked ) return ThrowTypeError ( "This statement is busy executing a query" ) ; if ( ! db -> GetState ( ) -> unsafe_mode ) { if ( db -> GetState ( ) -> iterators ) return ThrowTypeError ( "This database connection is busy executing a query" ) ; } ( ( void ) 0 ) ; const bool bound = stmt -> bound ; if ( ! bound ) { Binder binder ( handle ) ; if ( ! binder . Bind ( info , info . Length ( ) , stmt ) ) { sqlite3_clear_bindings ( handle ) ; return ; } ( ( void ) 0 ) ; } else if ( info . Length ( ) > 0 ) { return ThrowTypeError ( "This statement already has bound parameters" ) ; } ( ( void ) 0 ) ; db -> GetState ( ) -> busy = true ; v8 :: Isolate * isolate = info . GetIsolate ( ) ; if ( db -> Log ( isolate , handle ) ) { db -> GetState ( ) -> busy = false ; db -> ThrowDatabaseError ( ) ; if ( ! bound ) { sqlite3_clear_bindings ( handle ) ; } return ; } ( ( void ) 0 ) ; sqlite3* db_handle = db->GetHandle(); @@ -920,9 +923,9 @@ void Statement::JS_run (v8::FunctionCallbackInfo const & info) } db -> GetState ( ) -> busy = false ; db -> ThrowDatabaseError ( ) ; if ( ! bound ) { sqlite3_clear_bindings ( handle ) ; } return ; } -#line 176 "./src/objects/statement.lzz" +#line 179 "./src/objects/statement.lzz" void Statement::JS_get (v8::FunctionCallbackInfo const & info) -#line 176 "./src/objects/statement.lzz" +#line 179 "./src/objects/statement.lzz" { Statement * stmt = node :: ObjectWrap :: Unwrap < Statement > ( info . This ( ) ) ; if ( ! stmt -> returns_data ) return ThrowTypeError ( "This statement does not return data. Use run() instead" ) ; sqlite3_stmt * handle = stmt -> handle ; Database * db = stmt -> db ; if ( ! db -> GetState ( ) -> open ) return ThrowTypeError ( "The database connection is not open" ) ; if ( db -> GetState ( ) -> busy ) return ThrowTypeError ( "This database connection is busy executing a query" ) ; if ( stmt -> locked ) return ThrowTypeError ( "This statement is busy executing a query" ) ; const bool bound = stmt -> bound ; if ( ! bound ) { Binder binder ( handle ) ; if ( ! binder . Bind ( info , info . Length ( ) , stmt ) ) { sqlite3_clear_bindings ( handle ) ; return ; } ( ( void ) 0 ) ; } else if ( info . Length ( ) > 0 ) { return ThrowTypeError ( "This statement already has bound parameters" ) ; } ( ( void ) 0 ) ; db -> GetState ( ) -> busy = true ; v8 :: Isolate * isolate = info . GetIsolate ( ) ; if ( db -> Log ( isolate , handle ) ) { db -> GetState ( ) -> busy = false ; db -> ThrowDatabaseError ( ) ; if ( ! bound ) { sqlite3_clear_bindings ( handle ) ; } return ; } ( ( void ) 0 ) ; int status = sqlite3_step(handle); @@ -937,9 +940,9 @@ void Statement::JS_get (v8::FunctionCallbackInfo const & info) sqlite3_reset(handle); db -> GetState ( ) -> busy = false ; db -> ThrowDatabaseError ( ) ; if ( ! bound ) { sqlite3_clear_bindings ( handle ) ; } return ; } -#line 191 "./src/objects/statement.lzz" +#line 194 "./src/objects/statement.lzz" void Statement::JS_all (v8::FunctionCallbackInfo const & info) -#line 191 "./src/objects/statement.lzz" +#line 194 "./src/objects/statement.lzz" { Statement * stmt = node :: ObjectWrap :: Unwrap < Statement > ( info . This ( ) ) ; if ( ! stmt -> returns_data ) return ThrowTypeError ( "This statement does not return data. Use run() instead" ) ; sqlite3_stmt * handle = stmt -> handle ; Database * db = stmt -> db ; if ( ! db -> GetState ( ) -> open ) return ThrowTypeError ( "The database connection is not open" ) ; if ( db -> GetState ( ) -> busy ) return ThrowTypeError ( "This database connection is busy executing a query" ) ; if ( stmt -> locked ) return ThrowTypeError ( "This statement is busy executing a query" ) ; const bool bound = stmt -> bound ; if ( ! bound ) { Binder binder ( handle ) ; if ( ! binder . Bind ( info , info . Length ( ) , stmt ) ) { sqlite3_clear_bindings ( handle ) ; return ; } ( ( void ) 0 ) ; } else if ( info . Length ( ) > 0 ) { return ThrowTypeError ( "This statement already has bound parameters" ) ; } ( ( void ) 0 ) ; db -> GetState ( ) -> busy = true ; v8 :: Isolate * isolate = info . GetIsolate ( ) ; if ( db -> Log ( isolate , handle ) ) { db -> GetState ( ) -> busy = false ; db -> ThrowDatabaseError ( ) ; if ( ! bound ) { sqlite3_clear_bindings ( handle ) ; } return ; } ( ( void ) 0 ) ; v8 :: Local < v8 :: Context > ctx = isolate -> GetCurrentContext ( ) ; @@ -960,9 +963,9 @@ void Statement::JS_all (v8::FunctionCallbackInfo const & info) if (js_error) db->GetState()->was_js_error = true; db -> GetState ( ) -> busy = false ; db -> ThrowDatabaseError ( ) ; if ( ! bound ) { sqlite3_clear_bindings ( handle ) ; } return ; } -#line 212 "./src/objects/statement.lzz" +#line 215 "./src/objects/statement.lzz" void Statement::JS_iterate (v8::FunctionCallbackInfo const & info) -#line 212 "./src/objects/statement.lzz" +#line 215 "./src/objects/statement.lzz" { Addon * addon = static_cast < Addon * > ( info . Data ( ) . As < v8 :: External > ( ) -> Value ( ) ) ; v8 :: Isolate * isolate = info . GetIsolate ( ) ; @@ -972,9 +975,9 @@ void Statement::JS_iterate (v8::FunctionCallbackInfo const & info) addon->privileged_info = NULL; if (!maybeIterator.IsEmpty()) info.GetReturnValue().Set(maybeIterator.ToLocalChecked()); } -#line 222 "./src/objects/statement.lzz" +#line 225 "./src/objects/statement.lzz" void Statement::JS_bind (v8::FunctionCallbackInfo const & info) -#line 222 "./src/objects/statement.lzz" +#line 225 "./src/objects/statement.lzz" { Statement* stmt = node :: ObjectWrap :: Unwrap (info.This()); if (stmt->bound) return ThrowTypeError("The bind() method can only be invoked once per statement object"); @@ -985,9 +988,9 @@ void Statement::JS_bind (v8::FunctionCallbackInfo const & info) stmt->bound = true; info.GetReturnValue().Set(info.This()); } -#line 233 "./src/objects/statement.lzz" +#line 236 "./src/objects/statement.lzz" void Statement::JS_pluck (v8::FunctionCallbackInfo const & info) -#line 233 "./src/objects/statement.lzz" +#line 236 "./src/objects/statement.lzz" { Statement* stmt = node :: ObjectWrap :: Unwrap (info.This()); if (!stmt->returns_data) return ThrowTypeError("The pluck() method is only for statements that return data"); @@ -998,9 +1001,9 @@ void Statement::JS_pluck (v8::FunctionCallbackInfo const & info) stmt->mode = use ? Data::PLUCK : stmt->mode == Data::PLUCK ? Data::FLAT : stmt->mode; info.GetReturnValue().Set(info.This()); } -#line 244 "./src/objects/statement.lzz" +#line 247 "./src/objects/statement.lzz" void Statement::JS_expand (v8::FunctionCallbackInfo const & info) -#line 244 "./src/objects/statement.lzz" +#line 247 "./src/objects/statement.lzz" { Statement* stmt = node :: ObjectWrap :: Unwrap (info.This()); if (!stmt->returns_data) return ThrowTypeError("The expand() method is only for statements that return data"); @@ -1011,9 +1014,9 @@ void Statement::JS_expand (v8::FunctionCallbackInfo const & info) stmt->mode = use ? Data::EXPAND : stmt->mode == Data::EXPAND ? Data::FLAT : stmt->mode; info.GetReturnValue().Set(info.This()); } -#line 255 "./src/objects/statement.lzz" +#line 258 "./src/objects/statement.lzz" void Statement::JS_raw (v8::FunctionCallbackInfo const & info) -#line 255 "./src/objects/statement.lzz" +#line 258 "./src/objects/statement.lzz" { Statement* stmt = node :: ObjectWrap :: Unwrap (info.This()); if (!stmt->returns_data) return ThrowTypeError("The raw() method is only for statements that return data"); @@ -1024,9 +1027,9 @@ void Statement::JS_raw (v8::FunctionCallbackInfo const & info) stmt->mode = use ? Data::RAW : stmt->mode == Data::RAW ? Data::FLAT : stmt->mode; info.GetReturnValue().Set(info.This()); } -#line 266 "./src/objects/statement.lzz" +#line 269 "./src/objects/statement.lzz" void Statement::JS_safeIntegers (v8::FunctionCallbackInfo const & info) -#line 266 "./src/objects/statement.lzz" +#line 269 "./src/objects/statement.lzz" { Statement* stmt = node :: ObjectWrap :: Unwrap (info.This()); if ( stmt -> db -> GetState ( ) -> busy ) return ThrowTypeError ( "This database connection is busy executing a query" ) ; @@ -1035,9 +1038,9 @@ void Statement::JS_safeIntegers (v8::FunctionCallbackInfo const & else { if ( info . Length ( ) <= ( 0 ) || ! info [ 0 ] -> IsBoolean ( ) ) return ThrowTypeError ( "Expected " "first" " argument to be " "a boolean" ) ; stmt -> safe_ints = ( info [ 0 ] . As < v8 :: Boolean > ( ) ) -> Value ( ) ; } info.GetReturnValue().Set(info.This()); } -#line 275 "./src/objects/statement.lzz" +#line 278 "./src/objects/statement.lzz" void Statement::JS_columns (v8::FunctionCallbackInfo const & info) -#line 275 "./src/objects/statement.lzz" +#line 278 "./src/objects/statement.lzz" { Statement* stmt = node :: ObjectWrap :: Unwrap (info.This()); if (!stmt->returns_data) return ThrowTypeError("The columns() method is only for statements that return data"); @@ -1080,9 +1083,9 @@ void Statement::JS_columns (v8::FunctionCallbackInfo const & info) info.GetReturnValue().Set(columns); } -#line 318 "./src/objects/statement.lzz" +#line 321 "./src/objects/statement.lzz" void Statement::JS_busy (v8::Local _, v8::PropertyCallbackInfo const & info) -#line 318 "./src/objects/statement.lzz" +#line 321 "./src/objects/statement.lzz" { Statement* stmt = node :: ObjectWrap :: Unwrap (info.This()); info.GetReturnValue().Set(stmt->alive && stmt->locked); diff --git a/src/better_sqlite3.hpp b/src/better_sqlite3.hpp index c3f9262e0..0c0bcfd02 100644 --- a/src/better_sqlite3.hpp +++ b/src/better_sqlite3.hpp @@ -340,47 +340,47 @@ class Statement : public node::ObjectWrap explicit Statement (Database * db, sqlite3_stmt * handle, sqlite3_uint64 id, bool returns_data); #line 85 "./src/objects/statement.lzz" static void JS_new (v8::FunctionCallbackInfo const & info); -#line 153 "./src/objects/statement.lzz" +#line 156 "./src/objects/statement.lzz" static void JS_run (v8::FunctionCallbackInfo const & info); -#line 176 "./src/objects/statement.lzz" +#line 179 "./src/objects/statement.lzz" static void JS_get (v8::FunctionCallbackInfo const & info); -#line 191 "./src/objects/statement.lzz" +#line 194 "./src/objects/statement.lzz" static void JS_all (v8::FunctionCallbackInfo const & info); -#line 212 "./src/objects/statement.lzz" +#line 215 "./src/objects/statement.lzz" static void JS_iterate (v8::FunctionCallbackInfo const & info); -#line 222 "./src/objects/statement.lzz" +#line 225 "./src/objects/statement.lzz" static void JS_bind (v8::FunctionCallbackInfo const & info); -#line 233 "./src/objects/statement.lzz" +#line 236 "./src/objects/statement.lzz" static void JS_pluck (v8::FunctionCallbackInfo const & info); -#line 244 "./src/objects/statement.lzz" +#line 247 "./src/objects/statement.lzz" static void JS_expand (v8::FunctionCallbackInfo const & info); -#line 255 "./src/objects/statement.lzz" +#line 258 "./src/objects/statement.lzz" static void JS_raw (v8::FunctionCallbackInfo const & info); -#line 266 "./src/objects/statement.lzz" +#line 269 "./src/objects/statement.lzz" static void JS_safeIntegers (v8::FunctionCallbackInfo const & info); -#line 275 "./src/objects/statement.lzz" +#line 278 "./src/objects/statement.lzz" static void JS_columns (v8::FunctionCallbackInfo const & info); -#line 318 "./src/objects/statement.lzz" +#line 321 "./src/objects/statement.lzz" static void JS_busy (v8::Local _, v8::PropertyCallbackInfo const & info); -#line 323 "./src/objects/statement.lzz" +#line 326 "./src/objects/statement.lzz" Database * const db; -#line 324 "./src/objects/statement.lzz" +#line 327 "./src/objects/statement.lzz" sqlite3_stmt * const handle; -#line 325 "./src/objects/statement.lzz" +#line 328 "./src/objects/statement.lzz" Extras * const extras; -#line 326 "./src/objects/statement.lzz" +#line 329 "./src/objects/statement.lzz" bool alive; -#line 327 "./src/objects/statement.lzz" +#line 330 "./src/objects/statement.lzz" bool locked; -#line 328 "./src/objects/statement.lzz" +#line 331 "./src/objects/statement.lzz" bool bound; -#line 329 "./src/objects/statement.lzz" +#line 332 "./src/objects/statement.lzz" bool has_bind_map; -#line 330 "./src/objects/statement.lzz" +#line 333 "./src/objects/statement.lzz" bool safe_ints; -#line 331 "./src/objects/statement.lzz" +#line 334 "./src/objects/statement.lzz" char mode; -#line 332 "./src/objects/statement.lzz" +#line 335 "./src/objects/statement.lzz" bool const returns_data; }; #line 1 "./src/objects/statement-iterator.lzz" diff --git a/src/objects/statement.lzz b/src/objects/statement.lzz index 73dc3a82e..5e2c80570 100644 --- a/src/objects/statement.lzz +++ b/src/objects/statement.lzz @@ -123,14 +123,17 @@ private: tail += 2; for (char c; (c = *tail); ++tail) { if (c == '*' && tail[1] == '/') { - tail += 1; + tail += 2; break; } } } else if (c == '-' && tail[1] == '-') { tail += 2; for (char c; (c = *tail); ++tail) { - if (c == '\n') break; + if (c == '\n') { + ++tail; + break; + } } } else { sqlite3_finalize(handle); diff --git a/test/13.database.prepare.js b/test/13.database.prepare.js index 2cbe71175..71634d5ea 100644 --- a/test/13.database.prepare.js +++ b/test/13.database.prepare.js @@ -37,6 +37,12 @@ describe('Database#prepare()', function () { expect(() => this.db.prepare('CREATE TABLE people (name TEXT);CREATE TABLE animals (name TEXT)')).to.throw(RangeError); expect(() => this.db.prepare('CREATE TABLE people (name TEXT);/')).to.throw(RangeError); expect(() => this.db.prepare('CREATE TABLE people (name TEXT);-')).to.throw(RangeError); + expect(() => this.db.prepare('CREATE TABLE people (name TEXT);--\n/;')).to.throw(RangeError); + expect(() => this.db.prepare('CREATE TABLE people (name TEXT);--\nSELECT 123;')).to.throw(RangeError); + expect(() => this.db.prepare('CREATE TABLE people (name TEXT);-- comment\nSELECT 123;')).to.throw(RangeError); + expect(() => this.db.prepare('CREATE TABLE people (name TEXT);/**/-')).to.throw(RangeError); + expect(() => this.db.prepare('CREATE TABLE people (name TEXT);/**/SELECT 123;')).to.throw(RangeError); + expect(() => this.db.prepare('CREATE TABLE people (name TEXT);/* comment */SELECT 123;')).to.throw(RangeError); }); it('should create a prepared Statement object', function () { const stmt1 = this.db.prepare('CREATE TABLE people (name TEXT) '); @@ -57,4 +63,12 @@ describe('Database#prepare()', function () { assertStmt(this.db.prepare('BEGIN EXCLUSIVE'), 'BEGIN EXCLUSIVE', this.db, false, false); assertStmt(this.db.prepare('DELETE FROM data RETURNING *'), 'DELETE FROM data RETURNING *', this.db, true, false); }); + it('should create a prepared Statement object ignoring trailing comments and whitespace', function () { + assertStmt(this.db.prepare('SELECT 555; '), 'SELECT 555; ', this.db, true, true); + assertStmt(this.db.prepare('SELECT 555;-- comment'), 'SELECT 555;-- comment', this.db, true, true); + assertStmt(this.db.prepare('SELECT 555;--abc\n--de\n--f'), 'SELECT 555;--abc\n--de\n--f', this.db, true, true); + assertStmt(this.db.prepare('SELECT 555;/* comment */'), 'SELECT 555;/* comment */', this.db, true, true); + assertStmt(this.db.prepare('SELECT 555;/* comment */-- comment'), 'SELECT 555;/* comment */-- comment', this.db, true, true); + assertStmt(this.db.prepare('SELECT 555;-- comment\n/* comment */'), 'SELECT 555;-- comment\n/* comment */', this.db, true, true); + }); });