Mengambil Nilai Identitas atau Jumlah Otomatis

Artikel
04/08/2023

Kunci primer dalam database relasional adalah kolom atau kombinasi kolom yang selalu berisi nilai unik. Mengetahui nilai kunci primer memungkinkan Anda menemukan baris yang berisinya. Mesin database relasional, seperti SQL Server, Oracle, dan Microsoft Access/Jet mendukung pembuatan kolom yang bertahap secara otomatis yang dapat ditetapkan sebagai kunci primer. Nilai-nilai ini dihasilkan oleh server saat baris ditambahkan ke tabel. Di SQL Server, Anda mengatur properti identitas kolom, di Oracle Anda membuat Urutan, dan di Microsoft Access Anda membuat kolom AutoNumber.

DataColumn juga dapat digunakan untuk menghasilkan nilai yang bertambah secara otomatis dengan mengatur properti AutoIncrement ke true. Namun, Anda mungkin berakhir dengan nilai duplikat dalam instans terpisah dari DataTable, jika beberapa aplikasi klien secara independen menghasilkan nilai yang bertahap secara otomatis. Meminta server menghasilkan nilai yang bertambah secara otomatis menghilangkan potensi konflik dengan memungkinkan setiap pengguna untuk mengambil nilai yang dihasilkan untuk setiap baris yang disisipkan.

Selama panggilan ke metode Update dari DataAdapter, database dapat mengirim data kembali ke aplikasi ADO.NET Anda sebagai parameter output atau sebagai rekaman pertama yang dikembalikan dari kumpulan hasil pernyataan SELECT yang dijalankan dalam batch yang sama dengan pernyataan INSERT. ADO.NET dapat mengambil nilai-nilai ini dan memperbarui kolom terkait dalam yang DataRow sedang diperbarui.

Beberapa mesin database, seperti mesin database Microsoft Access Jet, tidak mendukung parameter output dan tidak dapat memproses beberapa pernyataan dalam satu batch. Saat bekerja dengan mesin database Jet, Anda dapat mengambil nilai AutoNumber baru yang dihasilkan untuk baris yang disisipkan dengan menjalankan perintah SELECT terpisah dalam penanganan aktivitas untuk RowUpdated peristiwa DataAdapter.

Catatan

Alternatif untuk menggunakan nilai penambahan otomatis adalah menggunakan metode NewGuid objek Guid untuk menghasilkan GUID, atau pengidentifikasi unik global, pada komputer klien yang dapat disalin ke server saat setiap baris baru dimasukkan. Metode NewGuid ini menghasilkan nilai biner 16 byte yang dibuat menggunakan algoritma yang memberikan probabilitas tinggi bahwa tidak ada nilai yang akan diduplikasi. Dalam database SQL Server, GUID disimpan dalam kolom uniqueidentifier yang mana dapat dihasilkan SQL Server secara otomatis menggunakan fungsi Transact-SQLNEWID(). Menggunakan GUID sebagai kunci primer dapat berdampak buruk pada performa. SQL Server menyediakan dukungan untuk fungsi NEWSEQUENTIALID(), yang menghasilkan GUID berurutan yang tidak dijamin unik secara global tetapi dapat diindeks lebih efisien.

Mengambil Nilai Kolom Identitas SQL Server

Saat bekerja dengan Microsoft SQL Server, Anda dapat membuat prosedur tersimpan dengan parameter output untuk mengembalikan nilai identitas untuk baris yang disisipkan. Tabel berikut ini menjelaskan tiga fungsi SQL Transact dalam SQL Server yang dapat digunakan untuk mengambil nilai kolom identitas.

Function	Deskripsi
SCOPE_IDENTITY	Mengembalikan nilai identitas terakhir dalam cakupan eksekusi saat ini. SCOPE_IDENTITY direkomendasikan untuk sebagian besar skenario.
@@IDENTITY	Berisi nilai identitas terakhir yang dihasilkan dalam tabel apa pun dalam sesi saat ini. @@IDENTITY dapat dipengaruhi oleh pemicu dan mungkin tidak mengembalikan nilai identitas yang Anda harapkan.
IDENT_CURRENT	Mengembalikan nilai identitas terakhir yang dihasilkan untuk tabel tertentu dalam sesi apa pun dan cakupan apa pun.

Prosedur tersimpan berikut menunjukkan cara menyisipkan baris ke dalam tabel Kategori dan menggunakan parameter output untuk mengembalikan nilai identitas baru yang dihasilkan oleh fungsi Transact-SQL SCOPE_IDENTITY().

CREATE PROCEDURE dbo.InsertCategory
  @CategoryName nvarchar(15),
  @Identity int OUT
AS
INSERT INTO Categories (CategoryName) VALUES(@CategoryName)
SET @Identity = SCOPE_IDENTITY()

Prosedur tersimpan kemudian dapat ditentukan sebagai sumber InsertCommand objek SqlDataAdapter. Properti CommandType dari InsertCommand harus diatur ke StoredProcedure. Output identitas diambil dengan membuat SqlParameter yang memiliki ParameterDirection dari Output. Ketika InsertCommand diproses, nilai identitas bertahap otomatis dikembalikan dan ditempatkan di kolom CategoryID baris saat ini jika Anda mengatur properti UpdatedRowSource dari perintah sisipkan ke UpdateRowSource.OutputParameters atau ke UpdateRowSource.Both.

Jika perintah sisipkan Anda menjalankan batch yang menyertakan pernyataan INSERT dan pernyataan SELECT yang mengembalikan nilai identitas baru, maka Anda dapat mengambil nilai baru dengan mengatur properti UpdatedRowSource dari perintah sisipkan ke UpdateRowSource.FirstReturnedRecord.

static void RetrieveIdentity(string connectionString)
{
    using (SqlConnection connection =
               new(connectionString))
    {
        // Create a SqlDataAdapter based on a SELECT query.
        SqlDataAdapter adapter =
            new(
            "SELECT CategoryID, CategoryName FROM dbo.Categories",
            connection)
            {
                //Create the SqlCommand to execute the stored procedure.
                InsertCommand = new SqlCommand("dbo.InsertCategory",
            connection)
                {
                    CommandType = CommandType.StoredProcedure
                }
            };

        // Add the parameter for the CategoryName. Specifying the
        // ParameterDirection for an input parameter is not required.
        adapter.InsertCommand.Parameters.Add(
           new SqlParameter("@CategoryName", SqlDbType.NVarChar, 15,
           "CategoryName"));

        // Add the SqlParameter to retrieve the new identity value.
        // Specify the ParameterDirection as Output.
        SqlParameter parameter =
            adapter.InsertCommand.Parameters.Add(
            "@Identity", SqlDbType.Int, 0, "CategoryID");
        parameter.Direction = ParameterDirection.Output;

        // Create a DataTable and fill it.
        DataTable categories = new();
        adapter.Fill(categories);

        // Add a new row.
        DataRow newRow = categories.NewRow();
        newRow["CategoryName"] = "New Category";
        categories.Rows.Add(newRow);

        adapter.Update(categories);

        Console.WriteLine("List All Rows:");
        foreach (DataRow row in categories.Rows)
        {
            {
                Console.WriteLine("{0}: {1}", row[0], row[1]);
            }
        }
    }
}

Private Sub RetrieveIdentity(ByVal connectionString As String)
    Using connection As SqlConnection = New SqlConnection( _
       connectionString)

        ' Create a SqlDataAdapter based on a SELECT query.
        Dim adapter As SqlDataAdapter = New SqlDataAdapter( _
           "SELECT CategoryID, CategoryName FROM dbo.Categories", _
           connection)

        ' Create the SqlCommand to execute the stored procedure. 
        adapter.InsertCommand = New SqlCommand("dbo.InsertCategory", _
           connection)
        adapter.InsertCommand.CommandType = CommandType.StoredProcedure

        ' Add the parameter for the CategoryName. Specifying the
        ' ParameterDirection for an input parameter is not required.
        adapter.InsertCommand.Parameters.Add( _
          "@CategoryName", SqlDbType.NVarChar, 15, "CategoryName")

        ' Add the SqlParameter to retrieve the new identity value.
        ' Specify the ParameterDirection as Output.
        Dim parameter As SqlParameter = _
           adapter.InsertCommand.Parameters.Add( _
          "@Identity", SqlDbType.Int, 0, "CategoryID")
        parameter.Direction = ParameterDirection.Output

        ' Create a DataTable and fill it.
        Dim categories As DataTable = New DataTable
        adapter.Fill(categories)

        ' Add a new row.
        Dim newRow As DataRow = categories.NewRow()
        newRow("CategoryName") = "New Category"
        categories.Rows.Add(newRow)

        ' Update the database.
        adapter.Update(categories)

        Console.WriteLine("List All Rows:")
        Dim row As DataRow
        For Each row In categories.Rows
            Console.WriteLine("{0}: {1}", row(0), row(1))
        Next
    End Using
End Sub

Menggabungkan Nilai Identitas Baru

Skenario umum adalah memanggil metode GetChanges untuk DataTable membuat salinan yang hanya berisi baris yang diubah, dan untuk menggunakan salinan baru saat memanggil metode Update dari DataAdapter. Ini sangat berguna ketika Anda perlu menyusun baris yang diubah ke komponen terpisah yang melakukan pembaruan. Setelah pembaruan, salinan dapat berisi nilai identitas baru yang kemudian harus digabungkan kembali ke aslinya DataTable. Nilai identitas baru kemungkinan berbeda dari nilai asli di DataTable. Untuk mencapai penggabungan, nilai asli kolom AutoIncrement dalam salinan harus dipertahankan, agar dapat menemukan dan memperbarui baris yang ada di asli DataTable, daripada menambahkan baris baru yang berisi nilai identitas baru. Namun, secara default nilai asli tersebut hilang setelah panggilan ke metodeUpdate dari DataAdapter, karena AcceptChanges secara implisit dipanggil untuk setiap DataRow yang diperbarui.

Ada dua cara untuk mempertahankan nilai asli dari DataColumn dalam DataRow selama pembaruan DataAdapter:

Metode pertama untuk mempertahankan nilai asli adalah mengatur properti AcceptChangesDuringUpdate dari DataAdapter ke false. Ini mempengaruhi setiap DataRow dalam DataTable yang sedang diperbarui. Untuk informasi selengkapnya dan contoh kode, lihat AcceptChangesDuringUpdate.
Metode kedua adalah menulis kode di penanganan aktivitas RowUpdated dari DataAdapter untuk mengatur ke Status hingga SkipCurrentRow. DataRow diperbarui tetapi nilai asli masing-masing DataColumn dipertahankan. Metode ini memungkinkan Anda mempertahankan nilai asli untuk beberapa baris dan bukan untuk yang lain. Misalnya, kode Anda dapat mempertahankan nilai asli untuk baris yang ditambahkan dan bukan untuk baris yang diedit atau dihapus dengan terlebih dahulu memeriksa StatementType lalu mengatur Status ke SkipCurrentRow hanya untuk baris dengan StatementType dari Insert.

Ketika salah satu metode ini digunakan untuk mempertahankan nilai asli dalam DataRow selama pembaruan DataAdapter, ADO.NET melakukan serangkaian tindakan untuk mengatur nilai saat ini dari DataRow ke nilai baru yang dikembalikan oleh parameter output atau oleh baris pertama yang dikembalikan dari kumpulan hasil, sambil tetap mempertahankan nilai asli di masing-masing DataColumn. Pertama, metode AcceptChanges dari DataRow dipanggil untuk mempertahankan nilai saat ini sebagai nilai asli, lalu nilai baru ditetapkan. Mengikuti tindakan ini, DataRows yang properti RowState-nya diatur ke Added akan mengatur properti mereka RowState ke Modified, yang mungkin tidak terduga.

Bagaimana hasil perintah diterapkan ke setiap DataRow yang diperbarui ditentukan oleh properti UpdatedRowSource dari masing-masing DbCommand. Properti ini diatur ke nilai dari enumerasi UpdateRowSource.

Tabel berikut ini menjelaskan bagaimana nilai enumerasi UpdateRowSource memengaruhi properti RowState di baris yang diperbarui.

Nama anggota	Deskripsi
Both	`AcceptChanges` dipanggil dan nilai parameter output dan/atau nilai di baris pertama dari setiap tataan hasil yang dikembalikan ditempatkan dalam yang `DataRow` sedang diperbarui. Jika tidak ada nilai yang akan diterapkan, `RowState` akan menjadi Unchanged.
FirstReturnedRecord	Jika baris dikembalikan, `AcceptChanges` dipanggil dan baris dipetakan ke baris yang diubah di `DataTable`, mengatur `RowState` ke `Modified`. Jika tidak ada baris yang dikembalikan, maka `AcceptChanges` tidak dipanggil dan `RowState` tetap `Added`.
None	Parameter atau baris yang dikembalikan diabaikan. Tidak ada panggilan ke `AcceptChanges` dan `RowState` tetap `Added`.
OutputParameters	`AcceptChanges` dipanggil dan parameter output apa pun dipetakan ke baris yang diubah di `DataTable`, mengatur `RowState` ke `Modified`. Jika tidak ada parameter output, `RowState` akan menjadi `Unchanged`.

Contoh

Contoh ini menunjukkan mengekstrak baris yang diubah dari DataTabledan menggunakan SqlDataAdapter untuk memperbarui sumber data dan mengambil nilai kolom identitas baru. InsertCommand menjalankan dua pernyataan transact-SQL; yang pertama adalah pernyataan INSERT, dan yang kedua adalah pernyataan SELECT yang menggunakan fungsi SCOPE_IDENTITY untuk mengambil nilai identitas.

INSERT INTO dbo.Shippers (CompanyName)
VALUES (@CompanyName);
SELECT ShipperID, CompanyName FROM dbo.Shippers
WHERE ShipperID = SCOPE_IDENTITY();

Properti UpdatedRowSource perintah sisipkan diatur ke UpdateRowSource.FirstReturnedRow dan properti MissingSchemaAction dari DataAdapter diatur ke MissingSchemaAction.AddWithKey. DataTable diisi dan kode menambahkan baris baru ke DataTable. Baris yang diubah kemudian diekstrak ke dalam DataTable yang baru, yang diteruskan ke DataAdapter, yang kemudian memperbarui server.

static void MergeIdentityColumns(string connectionString)
{
    using (SqlConnection connection =
               new(connectionString))
    {
        // Create the DataAdapter
        SqlDataAdapter adapter =
            new(
            "SELECT ShipperID, CompanyName FROM dbo.Shippers",
            connection)
            {
                //Add the InsertCommand to retrieve new identity value.
                InsertCommand = new SqlCommand(
            "INSERT INTO dbo.Shippers (CompanyName) " +
            "VALUES (@CompanyName); " +
            "SELECT ShipperID, CompanyName FROM dbo.Shippers " +
            "WHERE ShipperID = SCOPE_IDENTITY();", connection)
            };

        // Add the parameter for the inserted value.
        adapter.InsertCommand.Parameters.Add(
           new SqlParameter("@CompanyName", SqlDbType.NVarChar, 40,
           "CompanyName"));
        adapter.InsertCommand.UpdatedRowSource = UpdateRowSource.Both;

        // MissingSchemaAction adds any missing schema to
        // the DataTable, including identity columns
        adapter.MissingSchemaAction = MissingSchemaAction.AddWithKey;

        // Fill the DataTable.
        DataTable shipper = new();
        adapter.Fill(shipper);

        // Add a new shipper.
        DataRow newRow = shipper.NewRow();
        newRow["CompanyName"] = "New Shipper";
        shipper.Rows.Add(newRow);

        // Add changed rows to a new DataTable. This
        // DataTable will be used by the DataAdapter.
        DataTable dataChanges = shipper.GetChanges()!;

        // Add the event handler.
        adapter.RowUpdated +=
             OnRowUpdated;

        adapter.Update(dataChanges);
        connection.Close();

        // Merge the updates.
        shipper.Merge(dataChanges);

        // Commit the changes.
        shipper.AcceptChanges();

        Console.WriteLine("Rows after merge.");
        foreach (DataRow row in shipper.Rows)
        {
            {
                Console.WriteLine("{0}: {1}", row[0], row[1]);
            }
        }
    }
}

Private Sub MergeIdentityColumns(ByVal connectionString As String)

    Using connection As SqlConnection = New SqlConnection( _
       connectionString)

        ' Create the DataAdapter
        Dim adapter As SqlDataAdapter = New SqlDataAdapter( _
          "SELECT ShipperID, CompanyName FROM dbo.Shippers", connection)

        ' Add the InsertCommand to retrieve new identity value.
        adapter.InsertCommand = New SqlCommand( _
            "INSERT INTO dbo.Shippers (CompanyName) " & _
            "VALUES (@CompanyName); " & _
            "SELECT ShipperID, CompanyName FROM dbo.Shippers " & _
            "WHERE ShipperID = SCOPE_IDENTITY();", _
            connection)

        ' Add the parameter for the inserted value.
        adapter.InsertCommand.Parameters.Add( _
           New SqlParameter("@CompanyName", SqlDbType.NVarChar, 40, _
           "CompanyName"))
        adapter.InsertCommand.UpdatedRowSource = UpdateRowSource.Both

        ' MissingSchemaAction adds any missing schema to 
        ' the DataTable, including identity columns
        adapter.MissingSchemaAction = MissingSchemaAction.AddWithKey

        ' Fill the DataTable.
        Dim shipper As New DataTable
        adapter.Fill(shipper)

        ' Add a new shipper. 
        Dim newRow As DataRow = shipper.NewRow()
        newRow("CompanyName") = "New Shipper"
        shipper.Rows.Add(newRow)

        ' Add changed rows to a new DataTable. This
        ' DataTable will be used by the DataAdapter.
        Dim dataChanges As DataTable = shipper.GetChanges()

        ' Add the event handler. 
        AddHandler adapter.RowUpdated, New _
           SqlRowUpdatedEventHandler(AddressOf OnRowUpdated)

        ' Update the datasource with the modified records.
        adapter.Update(dataChanges)

        ' Merge the two DataTables.
        shipper.Merge(dataChanges)

        ' Commit the changes.
        shipper.AcceptChanges()

        Console.WriteLine("Rows after merge.")
        Dim row As DataRow
        For Each row In shipper.Rows
            Console.WriteLine("{0}: {1}", row(0), row(1))
        Next
    End Using
End Sub

Penanganan aktivitas OnRowUpdated memeriksa StatementType dari SqlRowUpdatedEventArgs untuk menentukan apakah baris tersebut adalah sisipan. Jika ya, maka properti Status diatur ke SkipCurrentRow. Baris diperbarui, tetapi nilai asli dalam baris dipertahankan. Dalam isi utama prosedur, metode Merge ini dipanggil untuk menggabungkan nilai identitas baru ke dalam aslinya DataTable, dan akhirnya AcceptChanges dipanggil.

protected static void OnRowUpdated(
    object sender, SqlRowUpdatedEventArgs e)
{
    // If this is an insert, then skip this row.
    if (e.StatementType == StatementType.Insert)
    {
        e.Status = UpdateStatus.SkipCurrentRow;
    }
}

Private Sub OnRowUpdated( _
    ByVal sender As Object, ByVal e As SqlRowUpdatedEventArgs)
    ' If this is an insert, then skip this row.
    If e.StatementType = StatementType.Insert Then
        e.Status = UpdateStatus.SkipCurrentRow
    End If
End Sub

Mengambil Nilai JumlahOtomatis Microsoft Access

Bagian ini menyertakan sampel yang memperlihatkan cara mengambil nilai Autonumber dari database Jet 4.0. Mesin database Jet tidak mendukung eksekusi beberapa pernyataan dalam batch atau penggunaan parameter output, sehingga tidak mungkin menggunakan salah satu teknik ini untuk mengembalikan nilai baru Autonumber yang ditetapkan ke baris yang disisipkan. Namun, Anda dapat menambahkan kode ke penanganan aktivitas RowUpdated yang menjalankan pernyataan @@IDENTITY SELECT terpisah untuk mengambil nilai Autonumber yang baru.

Contoh

Alih-alih menambahkan informasi skema menggunakan MissingSchemaAction.AddWithKey, contoh ini mengonfigurasi DataTable dengan skema yang benar sebelum memanggil OleDbDataAdapter untuk mengisi DataTable. Dalam hal ini, kolom CategoryID dikonfigurasi untuk mengurangi nilai yang ditetapkan setiap baris yang disisipkan mulai dari nol, dengan mengatur AutoIncrement ke true, AutoIncrementSeed ke 0, dan AutoIncrementStep ke -1. Kode kemudian menambahkan dua baris baru dan menggunakan GetChanges untuk menambahkan baris yang diubah ke DataTable yang baru yang diteruskan ke metode Update.

static OleDbConnection s_connection = default!;

static void MergeIdentityColumns(OleDbConnection connection)
{
    using (connection)
    {
        // Create a DataAdapter based on a SELECT query.
        OleDbDataAdapter adapter = new(
         "SELECT CategoryID, CategoryName FROM Categories",
         connection)
        {
            // Create the INSERT command for the new category.
            InsertCommand = new OleDbCommand(
          "INSERT INTO Categories (CategoryName) Values(?)", connection)
            {
                CommandType = CommandType.Text
            }
        };

        // Add the parameter for the CategoryName.
        adapter.InsertCommand.Parameters.Add(
          "@CategoryName", OleDbType.VarWChar, 15, "CategoryName");
        adapter.InsertCommand.UpdatedRowSource = UpdateRowSource.Both;

        // Create a DataTable
        DataTable categories = new();

        // Create the CategoryID column and set its auto
        // incrementing properties to decrement from zero.
        DataColumn catId = new()
        {
            DataType = Type.GetType("System.Int32"),
            ColumnName = "CategoryID",
            AutoIncrement = true,
            AutoIncrementSeed = 0,
            AutoIncrementStep = -1
        };
        categories.Columns.Add(catId);

        // Create the CategoryName column.
        categories.Columns.Add(new DataColumn
        {
            DataType = Type.GetType("System.String"),
            ColumnName = "CategoryName"
        });

        // Set the primary key on CategoryID.
        var pKey = new DataColumn[] { catId };
        categories.PrimaryKey = pKey;

        // Fetch the data and fill the DataTable
        adapter.Fill(categories);

        // Add a new row.
        DataRow newRow = categories.NewRow();
        newRow["CategoryName"] = "New Category";
        categories.Rows.Add(newRow);

        // Add another new row.
        DataRow newRow2 = categories.NewRow();
        newRow2["CategoryName"] = "Another New Category";
        categories.Rows.Add(newRow2);

        // Add changed rows to a new DataTable that will be
        // used to post the inserts to the database.
        DataTable dataChanges = categories.GetChanges()!;

        // Include an event to fill in the Autonumber value.
        adapter.RowUpdated +=
             OnRowUpdated;

        // Update the database, inserting the new rows.
        adapter.Update(dataChanges);

        Console.WriteLine("Rows before merge:");
        foreach (DataRow row in categories.Rows)
        {
            {
                Console.WriteLine("  {0}: {1}", row[0], row[1]);
            }
        }

        // Merge the two DataTables.
        categories.Merge(dataChanges);

        // Commit the changes.
        categories.AcceptChanges();

        Console.WriteLine("Rows after merge:");
        foreach (DataRow row in categories.Rows)
        {
            {
                Console.WriteLine("  {0}: {1}", row[0], row[1]);
            }
        }
    }
}

Shared connection As OleDbConnection = Nothing

Private Shared Sub MergeIdentityColumns(ByVal connection As OleDbConnection)
    Using connection

        ' Create a DataAdapter based on a SELECT query.
        Dim adapter As OleDbDataAdapter = New OleDbDataAdapter( _
          "SELECT CategoryID, CategoryName FROM Categories", _
          connection)

        ' Create the INSERT command for the new category.
        adapter.InsertCommand = New OleDbCommand( _
          "INSERT INTO Categories (CategoryName) Values(?)", connection)
        adapter.InsertCommand.CommandType = CommandType.Text

        ' Add the parameter for the CategoryName.
        adapter.InsertCommand.Parameters.Add( _
          "@CategoryName", OleDbType.VarWChar, 15, "CategoryName")
        adapter.InsertCommand.UpdatedRowSource = UpdateRowSource.Both

        ' Create a DataTable.
        Dim categories As DataTable = New DataTable

        ' Create the CategoryID column and set its auto
        ' incrementing properties to decrement from zero.
        Dim column As New DataColumn()
        column.DataType = System.Type.GetType("System.Int32")
        column.ColumnName = "CategoryID"
        column.AutoIncrement = True
        column.AutoIncrementSeed = 0
        column.AutoIncrementStep = -1
        categories.Columns.Add(column)

        ' Create the CategoryName column.
        column = New DataColumn()
        column.DataType = System.Type.GetType("System.String")
        column.ColumnName = "CategoryName"
        categories.Columns.Add(column)

        ' Set the primary key on CategoryID.
        Dim pKey(0) As DataColumn
        pKey(0) = categories.Columns("CategoryID")
        categories.PrimaryKey = pKey

        ' Fetch the data and fill the DataTable.
        adapter.Fill(categories)

        ' Add a new row.
        Dim newRow As DataRow = categories.NewRow()
        newRow("CategoryName") = "New Category"
        categories.Rows.Add(newRow)

        ' Add another new row.
        Dim newRow2 As DataRow = categories.NewRow()
        newRow2("CategoryName") = "Another New Category"
        categories.Rows.Add(newRow2)

        ' Add changed rows to a new DataTable that will be
        ' used to post the inserts to the database.
        Dim dataChanges As DataTable = categories.GetChanges()

        ' Include an event to fill in the Autonumber value.
        AddHandler adapter.RowUpdated, _
          New OleDbRowUpdatedEventHandler(AddressOf OnRowUpdated)

        ' Update the database, inserting the new rows.
        adapter.Update(dataChanges)

        Console.WriteLine("Rows before merge:")
        Dim row1 As DataRow
        For Each row1 In categories.Rows
            Console.WriteLine("  {0}: {1}", row1(0), row1(1))
        Next

        ' Merge the two DataTables.
        categories.Merge(dataChanges)

        ' Commit the changes.
        categories.AcceptChanges()

        Console.WriteLine("Rows after merge:")
        Dim row As DataRow
        For Each row In categories.Rows
            Console.WriteLine("  {0}: {1}", row(0), row(1))
        Next
    End Using
End Sub

Penanganan aktivitas RowUpdated menggunakan buka OleDbConnection yang sama dengan pernyataan Update dari OleDbDataAdapter. Hal tersebut memeriksa StatementType dari OleDbRowUpdatedEventArgs untuk baris yang disisipkan. Untuk setiap baris yang disisipkan, baris baru OleDbCommand dibuat untuk menjalankan pernyataan SELECT @@IDENTITY pada koneksi, mengembalikan nilai baru Autonumber, yang ditempatkan di kolom CategoryID dari DataRow. Properti Status kemudian diatur ke UpdateStatus.SkipCurrentRow untuk menekan panggilan tersembunyi ke AcceptChanges. Dalam isi utama prosedur, metode Merge dipanggil untuk menggabungkan dua objek DataTable, dan akhirnya AcceptChanges dipanggil.

static void OnRowUpdated(
  object sender, OleDbRowUpdatedEventArgs e)
{
    // Conditionally execute this code block on inserts only.
    if (e.StatementType == StatementType.Insert)
    {
        OleDbCommand cmdNewID = new("SELECT @@IDENTITY",
            s_connection);
        // Retrieve the Autonumber and store it in the CategoryID column.
        e.Row["CategoryID"] = (int)cmdNewID.ExecuteScalar()!;
        e.Status = UpdateStatus.SkipCurrentRow;
    }
}

Private Shared Sub OnRowUpdated( _
    ByVal sender As Object, ByVal e As OleDbRowUpdatedEventArgs)
    ' Conditionally execute this code block on inserts only.
    If e.StatementType = StatementType.Insert Then
        ' Retrieve the Autonumber and store it in the CategoryID column.
        Dim cmdNewID As New OleDbCommand("SELECT @@IDENTITY", _
           connection)
        e.Row("CategoryID") = CInt(cmdNewID.ExecuteScalar)
        e.Status = UpdateStatus.SkipCurrentRow
    End If
End Sub