Skip to content

feat: add missing update methods to bindings #28

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
raphasampaio merged 10 commits into from
Jan 18, 2026
Merged

feat: add missing update methods to bindings #28

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
73e3328
update
raphasampaio Jan 18, 2026
edf8492
update
raphasampaio Jan 18, 2026
129c9b8
update
raphasampaio Jan 18, 2026
8e1821f
update
raphasampaio Jan 18, 2026
60e68e8
update
raphasampaio Jan 18, 2026
8746e16
update
raphasampaio Jan 18, 2026
230db7e
update
raphasampaio Jan 18, 2026
958827d
update
raphasampaio Jan 18, 2026
b75d6ca
update
raphasampaio Jan 18, 2026
acb5c2b
update
raphasampaio Jan 18, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
252 changes: 246 additions & 6 deletions bindings/dart/lib/src/database.dart
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -889,16 +889,16 @@ class Database {
}

final dataStructure = switch (outDataStructure.value) {
0 => 'scalar',
1 => 'vector',
2 => 'set',
psr_data_structure_t.PSR_DATA_STRUCTURE_SCALAR => 'scalar',
psr_data_structure_t.PSR_DATA_STRUCTURE_VECTOR => 'vector',
psr_data_structure_t.PSR_DATA_STRUCTURE_SET => 'set',
_ => 'unknown',
};

final dataType = switch (outDataType.value) {
0 => 'integer',
1 => 'real',
2 => 'text',
psr_data_type_t.PSR_DATA_TYPE_INTEGER => 'integer',
psr_data_type_t.PSR_DATA_TYPE_REAL => 'real',
psr_data_type_t.PSR_DATA_TYPE_TEXT => 'text',
_ => 'unknown',
};

Expand Down Expand Up @@ -964,6 +964,246 @@ class Database {
}
}

// Update scalar attribute methods

/// Updates an integer scalar attribute value by element ID.
void updateScalarInteger(String collection, String attribute, int id, int value) {
_ensureNotClosed();

final arena = Arena();
try {
final err = bindings.psr_database_update_scalar_integer(
_ptr,
collection.toNativeUtf8(allocator: arena).cast(),
attribute.toNativeUtf8(allocator: arena).cast(),
id,
value,
);

if (err != psr_error_t.PSR_OK) {
throw DatabaseException.fromError(err, "Failed to update scalar integer '$collection.$attribute' for id $id");
}
} finally {
arena.releaseAll();
}
}

/// Updates a double scalar attribute value by element ID.
void updateScalarDouble(String collection, String attribute, int id, double value) {
_ensureNotClosed();

final arena = Arena();
try {
final err = bindings.psr_database_update_scalar_double(
_ptr,
collection.toNativeUtf8(allocator: arena).cast(),
attribute.toNativeUtf8(allocator: arena).cast(),
id,
value,
);

if (err != psr_error_t.PSR_OK) {
throw DatabaseException.fromError(err, "Failed to update scalar double '$collection.$attribute' for id $id");
}
} finally {
arena.releaseAll();
}
}

/// Updates a string scalar attribute value by element ID.
void updateScalarString(String collection, String attribute, int id, String value) {
_ensureNotClosed();

final arena = Arena();
try {
final err = bindings.psr_database_update_scalar_string(
_ptr,
collection.toNativeUtf8(allocator: arena).cast(),
attribute.toNativeUtf8(allocator: arena).cast(),
id,
value.toNativeUtf8(allocator: arena).cast(),
);

if (err != psr_error_t.PSR_OK) {
throw DatabaseException.fromError(err, "Failed to update scalar string '$collection.$attribute' for id $id");
}
} finally {
arena.releaseAll();
}
}

// Update vector attribute methods

/// Updates an integer vector attribute by element ID (replaces entire vector).
void updateVectorIntegers(String collection, String attribute, int id, List<int> values) {
_ensureNotClosed();

final arena = Arena();
try {
final nativeValues = arena<Int64>(values.length);
for (var i = 0; i < values.length; i++) {
nativeValues[i] = values[i];
}

final err = bindings.psr_database_update_vector_integers(
_ptr,
collection.toNativeUtf8(allocator: arena).cast(),
attribute.toNativeUtf8(allocator: arena).cast(),
id,
nativeValues,
values.length,
);

if (err != psr_error_t.PSR_OK) {
throw DatabaseException.fromError(err, "Failed to update vector integers '$collection.$attribute' for id $id");
}
} finally {
arena.releaseAll();
}
}

/// Updates a double vector attribute by element ID (replaces entire vector).
void updateVectorDoubles(String collection, String attribute, int id, List<double> values) {
_ensureNotClosed();

final arena = Arena();
try {
final nativeValues = arena<Double>(values.length);
for (var i = 0; i < values.length; i++) {
nativeValues[i] = values[i];
}

final err = bindings.psr_database_update_vector_doubles(
_ptr,
collection.toNativeUtf8(allocator: arena).cast(),
attribute.toNativeUtf8(allocator: arena).cast(),
id,
nativeValues,
values.length,
);

if (err != psr_error_t.PSR_OK) {
throw DatabaseException.fromError(err, "Failed to update vector doubles '$collection.$attribute' for id $id");
}
} finally {
arena.releaseAll();
}
}

/// Updates a string vector attribute by element ID (replaces entire vector).
void updateVectorStrings(String collection, String attribute, int id, List<String> values) {
_ensureNotClosed();

final arena = Arena();
try {
final nativePtrs = arena<Pointer<Char>>(values.length);
for (var i = 0; i < values.length; i++) {
nativePtrs[i] = values[i].toNativeUtf8(allocator: arena).cast();
}

final err = bindings.psr_database_update_vector_strings(
_ptr,
collection.toNativeUtf8(allocator: arena).cast(),
attribute.toNativeUtf8(allocator: arena).cast(),
id,
nativePtrs,
values.length,
);

if (err != psr_error_t.PSR_OK) {
throw DatabaseException.fromError(err, "Failed to update vector strings '$collection.$attribute' for id $id");
}
} finally {
arena.releaseAll();
}
}

// Update set attribute methods

/// Updates an integer set attribute by element ID (replaces entire set).
void updateSetIntegers(String collection, String attribute, int id, List<int> values) {
_ensureNotClosed();

final arena = Arena();
try {
final nativeValues = arena<Int64>(values.length);
for (var i = 0; i < values.length; i++) {
nativeValues[i] = values[i];
}

final err = bindings.psr_database_update_set_integers(
_ptr,
collection.toNativeUtf8(allocator: arena).cast(),
attribute.toNativeUtf8(allocator: arena).cast(),
id,
nativeValues,
values.length,
);

if (err != psr_error_t.PSR_OK) {
throw DatabaseException.fromError(err, "Failed to update set integers '$collection.$attribute' for id $id");
}
} finally {
arena.releaseAll();
}
}

/// Updates a double set attribute by element ID (replaces entire set).
void updateSetDoubles(String collection, String attribute, int id, List<double> values) {
_ensureNotClosed();

final arena = Arena();
try {
final nativeValues = arena<Double>(values.length);
for (var i = 0; i < values.length; i++) {
nativeValues[i] = values[i];
}

final err = bindings.psr_database_update_set_doubles(
_ptr,
collection.toNativeUtf8(allocator: arena).cast(),
attribute.toNativeUtf8(allocator: arena).cast(),
id,
nativeValues,
values.length,
);

if (err != psr_error_t.PSR_OK) {
throw DatabaseException.fromError(err, "Failed to update set doubles '$collection.$attribute' for id $id");
}
} finally {
arena.releaseAll();
}
}

/// Updates a string set attribute by element ID (replaces entire set).
void updateSetStrings(String collection, String attribute, int id, List<String> values) {
_ensureNotClosed();

final arena = Arena();
try {
final nativePtrs = arena<Pointer<Char>>(values.length);
for (var i = 0; i < values.length; i++) {
nativePtrs[i] = values[i].toNativeUtf8(allocator: arena).cast();
}

final err = bindings.psr_database_update_set_strings(
_ptr,
collection.toNativeUtf8(allocator: arena).cast(),
attribute.toNativeUtf8(allocator: arena).cast(),
id,
nativePtrs,
values.length,
);

if (err != psr_error_t.PSR_OK) {
throw DatabaseException.fromError(err, "Failed to update set strings '$collection.$attribute' for id $id");
}
} finally {
arena.releaseAll();
}
}

/// Closes the database and frees native resources.
void close() {
if (_isClosed) return;
Expand Down
Loading
Loading