ADO.NET Provider for Apache Kafka

Build 21.0.7940

INSERT Statements

To create new records, use INSERT statements.


The INSERT statement specifies the columns to be inserted and the new column values. You can specify the column values in a comma-separated list in the VALUES clause, as shown in the following example:

INSERT INTO <table_name> 
( <column_reference> [ , ... ] )
( { <expression> | NULL } [ , ... ] ) 

<expression> ::=
  | @ <parameter> 
  | ?
  | <literal>

You can use the ExecuteNonQuery method to execute data manipulation commands and retrieve the rows affected, as shown in the following example:


String connectionString = "User=admin;Password=pass;BootStrapServers=https://localhost:9091;Topic=MyTopic;";
using (ApacheKafkaConnection connection = new ApacheKafkaConnection(connectionString)) {
  int rowsAffected;
  ApacheKafkaCommand cmd = new ApacheKafkaCommand("INSERT INTO SampleTable_1 (Column1) VALUES ('John')", connection);
  rowsAffected = cmd.ExecuteNonQuery();


Dim connectionString As [String] = "User=admin;Password=pass;BootStrapServers=https://localhost:9091;Topic=MyTopic;"
Using connection As New ApacheKafkaConnection(connectionString)
  Dim rowsAffected As Integer
  Dim cmd As New ApacheKafkaCommand("INSERT INTO SampleTable_1 (Column1) VALUES ('John')", connection)
  rowsAffected = cmd.ExecuteNonQuery()
End Using

Copyright (c) 2021 CData Software, Inc. - All rights reserved.
Build 21.0.7940