热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

SqlCommandBuilder可批量新增与修改数据

一、简述在项目中有一个需要导入数据包的需求,数据包是一个XML的文件,里面存储有数据,那么读取文件后就形成一个DataTable,然后改怎么把这个DataTable的数据批量插入到

一、简述

  在项目中有一个需要导入数据包的需求,数据包是一个XML的文件,里面存储有数据,那么读取文件后就形成一个DataTable,然后改怎么把这个DataTable的数据批量插入到数据库里面去呢?用一个循环?循环虽然简单,但总结的有点别扭,所以还是用SqlCommandBuilder、SqlDataAdapter.update来批量插入数据吧。

二、内容

首先数据库的原数据

技术分享

 然后批量插入数据的代码

    private string con = "Data Source=.;Initial Catalog=TestDatabase;Integrated Security=True";
    private void DataBatchUpdate()
    {
        // 假数据
        DataTable dt = new DataTable();
        dt.Columns.Add("id", typeof(int));
        dt.Columns.Add("testName");

        DataRow dr = dt.NewRow();
        dr["id"] = "1";
        dr["testName"] = "白白";
        dt.Rows.Add(dr);

        SqlConnection sqlCon = new SqlConnection(con);
        SqlDataAdapter sqlDa = new SqlDataAdapter("select * from testDataTable ", sqlCon);
        DataSet sqlds = new DataSet();
        sqlDa.Fill(sqlds);

        // 数据库数据
        DataTable databaseData = sqlds.Tables[0];
        databaseData.Merge(dt);

        SqlCommandBuilder sqlcb = new SqlCommandBuilder(sqlDa);
        sqlDa.Update(databaseData);
    }

得出来的数据,里面就新增了一条数据

技术分享

  这里主要是 Merge 起来合并两张Table表,然后由SqlCommandBuilder与Update()来更新到数据。然而,函数Update() 是根据DataTable的RowState来更新表的。当用Merge合并了两张表后,各行的RowState就像下图

这里,先在原来代码的基础添加几行代码

    private string con = "Data Source=.;Initial Catalog=TestDatabase;Integrated Security=True";
    private void DataBatchUpdate()
    {
        // 假数据
        DataTable dt = new DataTable();
        dt.Columns.Add("id", typeof(int));
        dt.Columns.Add("testName");

        DataRow dr = dt.NewRow();
        dr["id"] = "1";
        dr["testName"] = "白白";
        dt.Rows.Add(dr);

        SqlConnection sqlCon = new SqlConnection(con);
        SqlDataAdapter sqlDa = new SqlDataAdapter("select * from testDataTable ", sqlCon);
        DataSet sqlds = new DataSet();
        sqlDa.Fill(sqlds);

        // 数据库数据
        DataTable databaseData = sqlds.Tables[0];
        databaseData.Merge(dt);

        // 显示表格没一行的状态
        databaseData.Columns.Add("updatedSate");
        for (int i = 0; i )
        {
            DataRow updatedRow = databaseData.Rows[i];
            updatedRow["updatedSate"] = updatedRow.RowState;
        }

        //SqlCommandBuilder sqlcb = new SqlCommandBuilder(sqlDa);
        //sqlDa.Update(databaseData);

        gridData.DataSource = databaseData;
        gridData.DataBind();

    }

得出的结果则显示最后一条的状态是 Added,所以就作为新数据插入到数据库去。

技术分享

那么,如果只是批量插入数据的话

SqlDataAdapter sqlDa = new SqlDataAdapter("select * from testDataTable ", sqlCon);

还可以这么写,就是获取到数据库表中的结构就可以了。

SqlDataAdapter sqlDa = new SqlDataAdapter("select * from testDataTable where 1=2", sqlCon);

  那么,如果只是单纯的批量插入数据库就简单多了,可是项目的导入数据包功能,如果用户是重复导入了呢?又或者导入的数据当中只有几个单元格的数据跟数据库的数据不同的呢?这该怎么解决?嗯??在代码中写个几句代码判断导入的数据在数据库表中是否存在,存在就把数据库表中的数据删掉,再新插入进去? - - !  显然不靠谱。

  后来就发现了有一种很神奇的方法,因为代码中的Update()是根据RowState来判断是否增删改的,上面只用到了“增”,那么只要RowsState是“改”就可以了。

首先代码

    private string con = "Data Source=.;Initial Catalog=TestDatabase;Integrated Security=True";
    private void DataBatchUpdate()
    {
        // 假数据
        DataTable dt = new DataTable();
        dt.Columns.Add("id", typeof(int));
        dt.Columns.Add("testName");

        DataRow dr = dt.NewRow();
        dr["id"] = "1";
        dr["testName"] = "白白";
        dt.Rows.Add(dr);

        SqlConnection sqlCon = new SqlConnection(con);
        SqlDataAdapter sqlDa = new SqlDataAdapter("select * from testDataTable ", sqlCon);
        DataSet sqlds = new DataSet();
        sqlDa.Fill(sqlds);

        // 数据库数据
        DataTable databaseData = sqlds.Tables[0];

        databaseData.PrimaryKey = new DataColumn[] { databaseData.Columns["id"] };  //设置DataTable的主键

        databaseData.Merge(dt);

        // 显示表格没一行的状态
        databaseData.Columns.Add("updatedSate");
        for (int i = 0; i )
        {
            DataRow updatedRow = databaseData.Rows[i];
            updatedRow["updatedSate"] = updatedRow.RowState;
        }

        SqlCommandBuilder sqlcb = new SqlCommandBuilder(sqlDa);
        sqlDa.Update(databaseData);

        gridData.DataSource = databaseData;
        gridData.DataBind();

    }

关键是为DataTable设置主键,然后Merge()就会自动修改,其RowState就变成了“改”,并且Name也随之变了。

技术分享   

技术分享  《=修改后  技术分享  《=修改前

这样就可以实现在相同的ID下自动批量更新数据的效果。  注:Update()更新数据的时候,数据库表中结构要有主键才可以。

SqlCommandBuilder 可批量新增与修改数据


推荐阅读
  • 本文介绍了lua语言中闭包的特性及其在模式匹配、日期处理、编译和模块化等方面的应用。lua中的闭包是严格遵循词法定界的第一类值,函数可以作为变量自由传递,也可以作为参数传递给其他函数。这些特性使得lua语言具有极大的灵活性,为程序开发带来了便利。 ... [详细]
  • 在说Hibernate映射前,我们先来了解下对象关系映射ORM。ORM的实现思想就是将关系数据库中表的数据映射成对象,以对象的形式展现。这样开发人员就可以把对数据库的操作转化为对 ... [详细]
  • 知识图谱——机器大脑中的知识库
    本文介绍了知识图谱在机器大脑中的应用,以及搜索引擎在知识图谱方面的发展。以谷歌知识图谱为例,说明了知识图谱的智能化特点。通过搜索引擎用户可以获取更加智能化的答案,如搜索关键词"Marie Curie",会得到居里夫人的详细信息以及与之相关的历史人物。知识图谱的出现引起了搜索引擎行业的变革,不仅美国的微软必应,中国的百度、搜狗等搜索引擎公司也纷纷推出了自己的知识图谱。 ... [详细]
  • 使用Ubuntu中的Python获取浏览器历史记录原文: ... [详细]
  • 高质量SQL书写的30条建议
    本文提供了30条关于优化SQL的建议,包括避免使用select *,使用具体字段,以及使用limit 1等。这些建议是基于实际开发经验总结出来的,旨在帮助读者优化SQL查询。 ... [详细]
  • CentOS 6.5安装VMware Tools及共享文件夹显示问题解决方法
    本文介绍了在CentOS 6.5上安装VMware Tools及解决共享文件夹显示问题的方法。包括清空CD/DVD使用的ISO镜像文件、创建挂载目录、改变光驱设备的读写权限等步骤。最后给出了拷贝解压VMware Tools的操作。 ... [详细]
  • 本文详细介绍了SQL日志收缩的方法,包括截断日志和删除不需要的旧日志记录。通过备份日志和使用DBCC SHRINKFILE命令可以实现日志的收缩。同时,还介绍了截断日志的原理和注意事项,包括不能截断事务日志的活动部分和MinLSN的确定方法。通过本文的方法,可以有效减小逻辑日志的大小,提高数据库的性能。 ... [详细]
  • 本文介绍了如何使用Power Design(PD)和SQL Server进行数据库反向工程的方法。通过创建数据源、选择要反向工程的数据表,PD可以生成物理模型,进而生成所需的概念模型。该方法适用于SQL Server数据库,对于其他数据库是否适用尚不确定。详细步骤和操作说明可参考本文内容。 ... [详细]
  • Oracle Database 10g许可授予信息及高级功能详解
    本文介绍了Oracle Database 10g许可授予信息及其中的高级功能,包括数据库优化数据包、SQL访问指导、SQL优化指导、SQL优化集和重组对象。同时提供了详细说明,指导用户在Oracle Database 10g中如何使用这些功能。 ... [详细]
  • 本文介绍了Oracle数据库中tnsnames.ora文件的作用和配置方法。tnsnames.ora文件在数据库启动过程中会被读取,用于解析LOCAL_LISTENER,并且与侦听无关。文章还提供了配置LOCAL_LISTENER和1522端口的示例,并展示了listener.ora文件的内容。 ... [详细]
  • 本文介绍了一个在线急等问题解决方法,即如何统计数据库中某个字段下的所有数据,并将结果显示在文本框里。作者提到了自己是一个菜鸟,希望能够得到帮助。作者使用的是ACCESS数据库,并且给出了一个例子,希望得到的结果是560。作者还提到自己已经尝试了使用"select sum(字段2) from 表名"的语句,得到的结果是650,但不知道如何得到560。希望能够得到解决方案。 ... [详细]
  • 本文讨论了在数据库打开和关闭状态下,重新命名或移动数据文件和日志文件的情况。针对性能和维护原因,需要将数据库文件移动到不同的磁盘上或重新分配到新的磁盘上的情况,以及在操作系统级别移动或重命名数据文件但未在数据库层进行重命名导致报错的情况。通过三个方面进行讨论。 ... [详细]
  • Oracle10g备份导入的方法及注意事项
    本文介绍了使用Oracle10g进行备份导入的方法及相关注意事项,同时还介绍了2019年独角兽企业重金招聘Python工程师的标准。内容包括导出exp命令、删用户、创建数据库、授权等操作,以及导入imp命令的使用。详细介绍了导入时的参数设置,如full、ignore、buffer、commit、feedback等。转载来源于https://my.oschina.net/u/1767754/blog/377593。 ... [详细]
  • 本文介绍了一种解析GRE报文长度的方法,通过分析GRE报文头中的标志位来计算报文长度。具体实现步骤包括获取GRE报文头指针、提取标志位、计算报文长度等。该方法可以帮助用户准确地获取GRE报文的长度信息。 ... [详细]
  • PDF内容编辑的两种小方法,你知道怎么操作吗?
    本文介绍了两种PDF内容编辑的方法:迅捷PDF编辑器和Adobe Acrobat DC。使用迅捷PDF编辑器,用户可以通过选择需要更改的文字内容并设置字体形式、大小和颜色来编辑PDF文件。而使用Adobe Acrobat DC,则可以通过在软件中点击编辑来编辑PDF文件。PDF文件的编辑可以帮助办公人员进行文件内容的修改和定制。 ... [详细]
author-avatar
真知棒
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有