nodejs
diff --git a/‎doc/api/sqlite.md‎
Lines changed: 2 additions & 1 deletion b/‎doc/api/sqlite.md‎
Lines changed: 2 additions & 1 deletion
diff --git a/‎src/node_sqlite.cc‎
Lines changed: 6 additions & 0 deletions b/‎src/node_sqlite.cc‎
Lines changed: 6 additions & 0 deletions
diff --git a/‎src/node_sqlite.h‎
Lines changed: 1 addition & 0 deletions b/‎src/node_sqlite.h‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎test/parallel/test-sqlite-session.js‎
Lines changed: 22 additions & 0 deletions b/‎test/parallel/test-sqlite-session.js‎
Lines changed: 22 additions & 0 deletions
@@ -1005,7 +1005,8 @@ wrapper around [`sqlite3session_patchset()`][].
 
 ### `session.close()`
 
-Closes the session. An exception is thrown if the database or the session is not open. This method is a
+Closes the session. An exception is thrown if the database or the session is not open,
+or if the session is currently generating a changeset or patchset. This method is a
 wrapper around [`sqlite3session_delete()`][].
 
 ### `session[Symbol.dispose]()`
 
@@ -4299,6 +4299,10 @@ void Session::Changeset(const FunctionCallbackInfo<Value>& args) {
       env, session->session_ == nullptr, "session is not open");
   THROW_AND_RETURN_IF_IN_AUTHORIZER(env, session->database_.get());
 
+  session->is_generating_changeset_ = true;
+  auto changeset_guard =
+      OnScopeLeave([&] { session->is_generating_changeset_ = false; });
+
   int nChangeset;
   void* pChangeset;
   int r = sqliteChangesetFunc(session->session_, &nChangeset, &pChangeset);
@@ -4324,6 +4328,8 @@ void Session::Close(const FunctionCallbackInfo<Value>& args) {
       env, !session->database_->IsOpen(), "database is not open");
   THROW_AND_RETURN_ON_BAD_STATE(
       env, session->session_ == nullptr, "session is not open");
+  THROW_AND_RETURN_ON_BAD_STATE(
+      env, session->is_generating_changeset_, "session is currently in use");
 
   session->Delete();
 }
 
@@ -458,6 +458,7 @@ class Session : public BaseObject {
   void Delete();
   sqlite3_session* session_;
   BaseObjectPtr<DatabaseSync> database_;  // The Parent Database
+  bool is_generating_changeset_ = false;
 
   friend class DatabaseSync;
 };
 
@@ -612,6 +612,28 @@ test('session.close() - closing twice', (t) => {
   });
 });
 
+test('session.close() - while generating changes throws exception', (t) => {
+  for (const method of ['changeset', 'patchset']) {
+    const database = new DatabaseSync(':memory:');
+    database.exec('CREATE TABLE data(key INTEGER PRIMARY KEY, value TEXT)');
+
+    const session = database.createSession({ table: 'data' });
+    database.exec("INSERT INTO data VALUES (1, 'a'), (2, 'b'), (3, 'c')");
+    database.setAuthorizer(() => {
+      session.close();
+      return constants.SQLITE_OK;
+    });
+
+    t.assert.throws(() => session[method](), {
+      code: 'ERR_INVALID_STATE',
+      message: 'session is currently in use',
+    });
+
+    database.setAuthorizer(null);
+    t.assert.notStrictEqual(session[method]().length, 0);
+  }
+});
+
 test('session - keeps its database alive after the db handle is dropped', async (t) => {
   const { gcUntil, onGC } = require('../common/gc');