用DataTable插入或更新SQL表

首先,我不能使用任何存储过程或视图。
我知道这看起来可能适得其反,但这些不是我的规定。

我有一个DataTable ,里面充满了数据。 它有一个复制结构到我的SQL表。

ID - NAME

SQL表格当前有一些数据,但我现在需要使用DataTable所有数据进行更新。 如果ID匹配,它需要更新SQl表,或者将ADD添加到唯一的列表中。

有没有什么办法可以只在我的WinForm应用程序中做到这一点?

到目前为止,我有:

SqlConnection sqlConn = new SqlConnection(ConnectionString);
            SqlDataAdapter adapter = new SqlDataAdapter(string.Format("SELECT * FROM {0}", cmboTableOne.SelectedItem), sqlConn);
            using (new SqlCommandBuilder(adapter))
            {
                try
                {
                    adapter.Fill(DtPrimary);
                    sqlConn.Open();
                    adapter.Update(DtPrimary);
                    sqlConn.Close();
                }
                catch (Exception es)
                {
                    MessageBox.Show(es.Message, @"SQL Connection", MessageBoxButtons.OK, MessageBoxIcon.Warning);
                }
            }

数据表:

        DataTable dtPrimary = new DataTable();

        dtPrimary.Columns.Add("pv_id");
        dtPrimary.Columns.Add("pv_name");

        foreach (KeyValuePair<int, string> valuePair in primaryList)
        {
            DataRow dataRow = dtPrimary.NewRow();

            dataRow["pv_id"] = valuePair.Key;
            dataRow["pv_name"] = valuePair.Value;

            dtPrimary.Rows.Add(dataRow);

SQL:

CREATE TABLE [dbo].[ice_provinces](
    [pv_id] [int] IDENTITY(1,1) NOT NULL,
    [pv_name] [nvarchar](50) NOT NULL,
 CONSTRAINT [PK_ice_provinces] PRIMARY KEY CLUSTERED 
(
    [pv_id] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
) ON [PRIMARY]

既然你要更新现有的值,并从数据表中插入新的数据,无论如何,我认为以下方法可能最适合你:

  • 从SQL表中删除所有现有数据(您可以使用TSQL TRUNCATE语句来提高速度和效率
  • 使用ADO.NET SqlBulcCopy类使用WriteToServer方法将数据从ADO.NET表批量插入到SQL表中。
  • 没有涉及的视图或存储过程,只是纯粹的TSQL和.NET代码。


    这是我的尝试,我至少能够更新数据库中的记录。 它与目前的解决方案有所不同,它在Fill()执行后将值应用于DataTable。 如果有必须更新的记录,则必须在DataTable中手动搜索,这就是缺点。 另一件事是,我意识到,如果您没有正确设置MissingSchemaAction,DataTable不会从数据库继承表模式。

    所以这里是示例代码(完整的ConsoleApplication):

    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Data.SqlClient;
    using System.Data;
    
    namespace SQLCommandBuilder
    {
        class Program
        {
            static void Main(string[] args)
            {
                SqlConnectionStringBuilder ConnStringBuilder = new SqlConnectionStringBuilder();
                ConnStringBuilder.DataSource = @"(local)SQLEXPRESS";
                ConnStringBuilder.InitialCatalog = "TestUndSpiel";
                ConnStringBuilder.IntegratedSecurity = true;
    
                SqlConnection sqlConn = new SqlConnection(ConnStringBuilder.ConnectionString);
    
                SqlDataAdapter adapter = new SqlDataAdapter(string.Format("SELECT * FROM {0}", "ice_provinces"), sqlConn);
                adapter.MissingSchemaAction = MissingSchemaAction.AddWithKey;   // needs to be set to apply table schema from db to datatable
    
                using (new SqlCommandBuilder(adapter))
                {
                    try
                    {
                        DataTable dtPrimary = new DataTable();                                   
    
                        adapter.Fill(dtPrimary);
    
                        // this would be a record you identified as to update:
                        dtPrimary.Rows[1]["pv_name"] = "value";
    
                        sqlConn.Open();
                        adapter.Update(dtPrimary);
                        sqlConn.Close();
                    }
                    catch (Exception es)
                    {
                        Console.WriteLine(es.Message);
                        Console.Read();
                    }
                }
            }
        }
    }
    
    链接地址: http://www.djcxy.com/p/14733.html

    上一篇: Insert or Update SQL Table with DataTable

    下一篇: When to use CouchDB over MongoDB and vice versa