Tagged: SQLServer

C# SqlBulkCopy 批量写入数据

最近在写 一个项目,数据来自WebService,然后插入数据库。但在写入库的时候总是报错,所以记录下!

XMl转DataTable

/// <summary>
/// XMLNode转DataTable
/// </summary>
/// <param name="Data">XMLNode节点</param>
/// <param name="xpath">Xpath</param>
/// <returns></returns>
public static DataTable GetDataTable(XmlNode Data, string xpath)
{
	XmlNodeList xmlRows = Data.SelectNodes(xpath);
	if ((xmlRows == null) || (xmlRows.Count == 0)) return null;

	DataTable dt = new DataTable();
	foreach (XmlNode xmlColumn in xmlRows[0].ChildNodes)
	{
		if (xmlColumn.Name.ToLower() != "locators")
		{
			dt.Columns.Add(xmlColumn.Name);
		}
		else
		{
			foreach (XmlNode loc in xmlColumn.SelectSingleNode("locator").ChildNodes)
			{
				dt.Columns.Add(loc.Name);
			}
		}
	}

	foreach (XmlNode xmlRow in xmlRows)
	{
		DataRow dr = dt.NewRow();
		foreach (XmlNode xmlColumn in xmlRow.ChildNodes)
		{
			if (xmlColumn.Name.ToLower() != "locators")
			{
				dr[xmlColumn.Name] = xmlRow[xmlColumn.Name].InnerText;
			}
			else
			{
				foreach (XmlNode loc in xmlColumn.SelectSingleNode("locator").ChildNodes)
				{
					dr[loc.Name] = xmlRow.SelectSingleNode(@"locators/locator/" + loc.Name).InnerText;
				}
			}
		}
		dt.Rows.Add(dr);
	}
	dt.AcceptChanges();

	return dt;
}

获取XML所有的单据行封装成DataTable

/// <summary>
/// XMLNodeList 转 DataTable
/// </summary>
/// <param name="xmlNodeList">xmlNodeList</param>
/// <param name="xpath">xpath</param>
/// <returns></returns>
public static DataTable GetDataTable(XmlNodeList xmlNodeList,string xpath)
{
	if (xmlNodeList.Count == 0 || string.IsNullOrEmpty(xpath))
		return null;

	DataTable dataTable = new DataTable();
	foreach (XmlElement item in xmlNodeList[0].ChildNodes)
	{
		dataTable.Columns.Add(item.Name.ToLower());
	}

	foreach (XmlNode item in xmlNodeList)
	{
		DataRow dataRow = dataTable.NewRow();
		foreach (XmlElement xmlelement in item.ChildNodes)
		{
			dataRow[xmlelement.Name] = xmlelement.InnerText;
		}
		dataTable.Rows.Add(dataRow);
	}
	dataTable.AcceptChanges();
	return dataTable;
}

批量插入数据

使用SqlBulkCopy的时候,它不是按照DataColumn的名称来对照数据库列名称的,它是按照DataTable的顺序来对应数据库列。所以一定要注意。若DataTable的列与数据库列不对应,可以使用ColumnMappings来建立对应关系。

public static void Insert(DataTable dataTable,string TableName)
{
	try
	{
		using (SqlConnection Connection = new SqlConnection(connectionString))
		{
			if (Connection.State != ConnectionState.Open)
				Connection.Open();

			using(SqlTransaction transaction = Connection.BeginTransaction())
			{
				using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(Connection, SqlBulkCopyOptions.Default, transaction))
				{
					sqlBulkCopy.BatchSize = dataTable.Rows.Count;
					sqlBulkCopy.DestinationTableName = TableName;

					// 映射表关系
					foreach (DataColumn column in dataTable.Columns)
					{
						sqlBulkCopy.ColumnMappings.Add(new SqlBulkCopyColumnMapping(column.ColumnName, column.ColumnName));
					}

					try
					{
						sqlBulkCopy.WriteToServer(dataTable);
						transaction.Commit();
					}
					catch (Exception)
					{
						transaction.Rollback();
						throw;
					}
					finally
					{
						Connection.Close();
					}
				}
			}
		}
	}
	catch (Exception)
	{
		throw;
	}
}

update from

在某些情况下,我们需要update数据,但数据来自其他表,通常我们是这样

UPDATE table1 alias
SET (column_name, column_name ) = (
SELECT (column_name, column_name)
FROM table2
WHERE column_name = alias.column_name)
WHERE column_name = VALUE;

但更新的列太多的话,那就非常麻烦。。

在MS SQL里面,我们可以这样

UPDATE FT_1_49E74BA98FF7886574E1
SET
  FN01 = v.su00, -- FN01、姓名
  FN02 = v.su36, -- FN02、部门
  FN03 = v.su34, -- FN03、岗位
  FN04 = v.su21 --FN04、入职时间
FROM FE_BASE5..GROUP_USER_V AS v
WHERE FN09 = v.su01
      AND FN09 = 'AC0001';

Oracle 和 DB2 可以这样

UPDATE A SET (A1, A2, A3) = (SELECT B1, B2, B3 FROM B WHERE A.ID = B.ID)

SQLSERVER 存储过程及触发器

最近遇到一个业务。客户要求维护一个请假表,包含员工信息,请假信息!每年1月1日需要给员工增加新一年的年假,但3月才清除去年未修的年假!每次员工请假审批成功后需要同步更新假期表。

增加年假

USE [FE_APP5]
GO

IF  EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[dbo].[Annual_leave]') AND type in (N'P', N'PC'))
	DROP PROCEDURE [dbo].[Annual_leave]
GO

USE [FE_APP5]
GO

/****** Object:  StoredProcedure [dbo].[Annual_leave]    Script Date: 11/07/2017 18:10:29 ******/
SET ANSI_NULLS ON
GO

SET QUOTED_IDENTIFIER ON
GO


create procedure [dbo].[Annual_leave]

as
	declare @FN01 varchar(20)	-- 员工号
	declare @FN07 int -- 剩余年假
	declare @FN05 int -- 年假天数
	declare @FN04 date -- 入职时间
	declare @day int = 5 -- 默认年假天数
	declare @currentyear int
	declare @year int

	declare my_cur cursor for select FN01,FN05,FN07,FN04 from FT_1_49E74BA98FF7886574E1
	
	open my_cur
	
	fetch next from my_cur into @FN01,@FN05,@FN07,@FN04
	
	while @@FETCH_STATUS = 0
	begin
		
		--print @FN01
		--print @FN05
		--print @FN07
		
		 -- 当年假期计算规则
		if MONTH(@FN04) < 7 
			set @currentyear = YEAR(getdate()) - YEAR(@FN04) + @day
		else if MONTH(@FN04) >= 7
			set @currentyear = YEAR(getdate()) - YEAR(@FN04) + @day - 1
			
		print @currentyear
		
		if @currentyear > 12
			set @currentyear = 12
		set @year = @currentyear + @FN07 -- 当前总年假
		--print @year
		
		UPDATE FT_1_49E74BA98FF7886574E1 SET FN05 = @year,FN07 = @year,FN06 = 0,FN08 = @FN07 where FN01 = @FN01;
		fetch next from my_cur into @FN01,@FN05,@FN07,@FN04
	end
	close my_cur
	deallocate my_cur


--select * from FT_1_49E74BA98FF7886574E1

--exec Annual_leave
GO

以上使用了游标!
Read more

MSSQL数据库恢复的正确步骤

  • 直接在【数据库】上右键,选择【还原数据库】
  • 在【还原数据库】界面,配置好【源设备】的路径,【目标数据库】里面自动会出现你需要还原的数据库的名称,选择它
  • 刚才添加的备份集,点击确定即可。

SQL Server之存储过程(PROCEDURE )

什么是存储过程呢?

存储过程就是作为可执行对象存放在数据库中的一个或多个SQL命令。
通俗来讲:存储过程其实就是能完成一定操作的一组SQL语句。

那为什么要用存储过程呢?

  1. 存储过程只在创造时进行编译,以后每次执行存储过程都不需再重新编译,而一般SQL语句每执行一次就编译一次,所以使用存储过程可提高数据库执行速度。
  2. 当对数据库进行复杂操作时,可将此复杂操作用存储过程封装起来与数据库提供的事务处理结合一起使用。
  3. 存储过程可以重复使用,可减少数据库开发人员的工作量。
  4. 安全性高,可设定只有某些用户才具有对指定存储过程的使用权。
--------------创建存储过程-----------------
CREATE PROC [ EDURE ] procedure_name [ ; number ]
    [ { @parameter data_type }
        [ VARYING ] [ = default ] [ OUTPUT ]
    ] [ ,...n ]
[ WITH
    { RECOMPILE | ENCRYPTION | RECOMPILE , ENCRYPTION } ]
[ FOR REPLICATION ]
AS sql_statement [ ...n ]
 
--------------调用存储过程-----------------
EXECUTE Procedure_name '' --存储过程如果有参数,后面加参数格式为:@参数名=value,也可直接为参数值value
 
--------------删除存储过程-----------------
drop procedure procedure_name    --在存储过程中能调用另外一个存储过程,而不能删除另外一个存储过程
 
-- 参数解释
-- procedure_name :存储过程的名称,在前面加#为局部临时存储过程,加##为全局临时存储过程。
 
-- number:是可选的整数,用来对同名的过程分组,以便用一条 DROP PROCEDURE 语句即可将同组的过程一起除去。例如,名为 orders 的应用程序使用的过程可以命名为 orderproc;1、orderproc;2 等。DROP PROCEDURE orderproc -- 语句将除去整个组。如果名称中包含定界标识符,则数字不应包含在标识符中,只应在 procedure_name 前后使用适当的定界符。 
 
-- @parameter: 存储过程的参数。可以有一个或多个。用户必须在执行过程时提供每个所声明参数的值(除非定义了该参数的默认值)。存储过程最多可以有 2.100 个参数。 
-- 使用 @ 符号作为第一个字符来指定参数名称。参数名称必须符合标识符的规则。每个过程的参数仅用于该过程本身;相同的参数名称可以用在其它过程中。默认情况下,参数只能代替常量,而不能用于代替表名、列名或其它数据库对象的名称。有关更多信息,请参见 EXECUTE。 
 
-- data_type:参数的数据类型。所有数据类型(包括 text、ntext 和 image)均可以用作存储过程的参数。不过,cursor 数据类型只能用于 OUTPUT 参数。如果指定的数据类型为 cursor,也必须同时指定 VARYING 和 OUTPUT 关键字。有关 SQL Server -- 提供的数据类型及其语法的更多信息,请参见数据类型。 
-- 说明 对于可以是 cursor 数据类型的输出参数,没有最大数目的限制。 
 
-- VARYING: 指定作为输出参数支持的结果集(由存储过程动态构造,内容可以变化)。仅适用于游标参数。 
 
-- default: 参数的默认值。如果定义了默认值,不必指定该参数的值即可执行过程。默认值必须是常量或 NULL。如果过程将对该参数使用 LIKE 关键字,那么默认值中可以包含通配符(%、_、[] 和 [^])。
 
-- OUTPUT :表明参数是返回参数。该选项的值可以返回给 EXEC[UTE]。使用 OUTPUT 参数可将信息返回给调用过程。Text、ntext 和 image 参数可用作 OUTPUT 参数。使用 OUTPUT 关键字的输出参数可以是游标占位符。 
 
-- RECOMPILE: 表明 SQL Server 不会缓存该过程的计划,该过程将在运行时重新编译。在使用非典型值或临时值而不希望覆盖缓存在内存中的执行计划时,请使用 RECOMPILE 选项。
 
-- ENCRYPTION: 表示 SQL Server 加密 syscomments 表中包含 CREATE PROCEDURE 语句文本的条目。使用 ENCRYPTION 可防止将过程作为 SQL Server 复制的一部分发布。 说明 在升级过程中,SQL Server 利用存储在 syscomments 中的加密注释来重新创建加密过程。 
 
-- FOR REPLICATION :指定不能在订阅服务器上执行为复制创建的存储过程。.使用 FOR REPLICATION 选项创建的存储过程可用作存储过程筛选,且只能在复制过程中执行。本选项不能和 WITH RECOMPILE 选项一起使用。 
 
-- AS :指定过程要执行的操作。
 
-- sql_statement :过程中要包含的任意数目和类型的 Transact-SQL 语句。但有一些限制。

无参数存储过程

CREATE PROCEDURE testproc
-- WITH ENCRYPTION, RECOMPILE, EXECUTE AS CALLER|SELF|OWNER| 'user_name'
AS
    SELECT TOP 10 * FROM NC..bd_deptdoc
GO

Read more