bulkInsertArray method

int bulkInsertArray(int connectionId, String table, List<String> columns, Uint8List dataBuffer, int rowCount,)

Performs a bulk insert operation.

Inserts multiple rows into table using the specified columns. The dataBuffer contains the data as a binary buffer. The rowCount specifies how many rows are in dataBuffer.

Returns the number of rows inserted on success, -1 on failure.

Implementation

int bulkInsertArray(
  int connectionId,
  String table,
  List<String> columns,
  Uint8List dataBuffer,
  int rowCount,
) {
  final tablePtr = table.toNativeUtf8();
  final colPtrs = malloc<ffi.Pointer<bindings.Utf8>>(columns.length);
  final utf8Ptrs = <ffi.Pointer<ffi.Opaque>>[];
  try {
    for (var i = 0; i < columns.length; i++) {
      final p = columns[i].toNativeUtf8();
      utf8Ptrs.add(p);
      (colPtrs + i).value = p.cast<bindings.Utf8>();
    }
    final rowsInserted = malloc<ffi.Uint32>();
    try {
      final dataPtr = _allocUint8List(dataBuffer);
      try {
        final code = _bindings.odbc_bulk_insert_array(
          connectionId,
          tablePtr.cast<bindings.Utf8>(),
          colPtrs,
          columns.length,
          dataPtr,
          dataBuffer.length,
          rowCount,
          rowsInserted,
        );
        if (code != 0) return -1;
        return rowsInserted.value;
      } finally {
        malloc.free(dataPtr);
      }
    } finally {
      malloc.free(rowsInserted);
    }
  } finally {
    utf8Ptrs.forEach(malloc.free);
    malloc
      ..free(colPtrs)
      ..free(tablePtr);
  }
}