#include <CDP2SQL/CDP2SQL.h>
#include <CppSQLite3/SQLite3Factory.h>

using namespace CDP2SQL;

...

try
{
  Database db(SQLite3Factory().Create(), "my.db");
  db.Execute("CREATE TABLE IF NOT EXISTS my_table(id INTEGER, payload BLOB, note TEXT);");

  BulkInserter inserter(db, "my_table", {"id", "payload", "note"});
  inserter.SetColumnTypeHint(1, IDatabaseBulkInserter::TypeHint::BLOB);

  std::string payload;
  payload.push_back('\0');
  payload.push_back('A');
  payload.push_back('\xff');

  std::vector<Utils::Variant> row;
  row.emplace_back(Utils::Variant(1));
  row.emplace_back(Utils::Variant(payload));
  row.emplace_back(Utils::Variant(std::string("some text")));
  inserter.AddRow(row);

  inserter.Commit();
}
catch (const SQLException& e)
{
  printf("Error occurred: %s\n", e.Message());
}

Member Function Documentation

BulkInserter::BulkInserter()

The default constructor. Use this if you need to delay calling Open.

BulkInserter::BulkInserter(Database &db, const std::string &table, const std::vector<std::string> &columns)

Constructs and opens a bulk inserter.

Equivalent to default-constructing and then calling Open.

[delete] BulkInserter::BulkInserter(const BulkInserter &)

Copy constructor.

BulkInserter::~BulkInserter()

Destructor. Calls Cancel to ensure that any pending work is rolled back/canceled.

void BulkInserter::AddRow(const std::vector<Utils::Variant> &values)

Adds a single row to the current batch. The number of values must match the number of columns passed when creating the inserter.

A Utils::Variant with type Utils::eUNDEFINED (or !isValid()) is treated as SQL NULL.

Throws CDP2SQL::SQLException on errors (e.g. mismatched row size, conversion errors, driver errors).

void BulkInserter::Cancel()

Aborts and discards the current batch.

After Cancel returns, the inserter is ready to accept a new batch via AddRow.

void BulkInserter::Commit()

Finalizes and flushes the current batch.

After Commit returns, the inserter is ready to accept a new batch via AddRow.

bool BulkInserter::IsOpen() const

Returns whether this object has been opened successfully.

void BulkInserter::Open(Database &db, const std::string &table, const std::vector<std::string> &columns)

Opens the bulk inserter for a specific table and columns.

BulkInserter will use an optimized backend-specific bulk insert implementation when available (e.g. COPY FROM for PostgreSQL); otherwise it uses a prepared INSERT statement inside a transaction as a portable fallback.

Parameters:

• db - Connected database instance.
• table - Target table name.
• columns - Column names in the same order as later values are passed to AddRow.

void BulkInserter::SetColumnTypeHint(std::size_t column, IDatabaseBulkInserter::TypeHint hint)

Sets an optional type hint for a column.

The column is the 0-based column index within the columns list used to create the inserter.

The hint is an implementation-defined integer value; callers should use values from CDP2SQL::IDatabaseBulkInserter::TypeHint for portable hints, e.g. TypeHint::BLOB to indicate that the column should be treated as a binary large object.

Backend-specific/custom hints may use integer values greater than 100.