用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]
既然你要更新现有的值,并从数据表中插入新的数据,无论如何,我认为以下方法可能最适合你:
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