Skip to content

Commit d0e4ec8

Browse files
authored
check for closed connection in changes (#251)
1 parent 9936a14 commit d0e4ec8

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

c_src/sqlite3_nif.c

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -341,6 +341,10 @@ exqlite_changes(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[])
341341
return make_error_tuple(env, "invalid_connection");
342342
}
343343

344+
if (conn->db == NULL) {
345+
return make_error_tuple(env, "connection_closed");
346+
}
347+
344348
int changes = sqlite3_changes(conn->db);
345349
return make_ok_tuple(env, enif_make_int(env, changes));
346350
}
@@ -386,7 +390,7 @@ exqlite_prepare(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[])
386390
if (conn->db == NULL) {
387391
enif_mutex_unlock(conn->mutex);
388392
enif_release_resource(statement);
389-
return make_error_tuple(env, "connection closed");
393+
return make_error_tuple(env, "connection_closed");
390394
}
391395
rc = sqlite3_prepare_v3(conn->db, (char*)bin.data, bin.size, 0, &statement->statement, NULL);
392396
enif_mutex_unlock(conn->mutex);

0 commit comments

Comments
 (0)