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 = _sqlCache.acquire(table);
  final colPtrs = malloc<ffi.Pointer<bindings.Utf8>>(columns.length);
  try {
    for (var i = 0; i < columns.length; i++) {
      (colPtrs + i).value = _sqlCache.acquire(columns[i]);
    }
    final rowsInserted = _bulkRowsInsertedPtr();
    return _withByteBuffer(dataBuffer, (dataPtr) {
          final code = _bindings.odbc_bulk_insert_array(
            connectionId,
            tablePtr,
            colPtrs,
            columns.length,
            dataPtr,
            dataBuffer.length,
            rowCount,
            rowsInserted,
          );
          if (code != 0) return -1;
          return rowsInserted.value;
        }) ??
        -1;
  } finally {
    malloc.free(colPtrs);
  }
}