快捷導(dǎo)航

將DataTable作為存儲過程參數(shù)的用法實例詳解

更新時間：2013年05月23日 18:11:07 作者：

需要向存儲過程中傳遞字符串，今天看了下SQL Server 2008的新特性，發(fā)現(xiàn)有表變量的使用，及其將DataTable作為參數(shù)的用法，下面與大家分享下

最近工作中寫了幾個存儲過程，需要向存儲過程中傳遞字符串，因為SQL Server 2000中沒有內(nèi)置類似于 split 的函數(shù)，只好自己處理，將前臺數(shù)據(jù)集中的一列用逗號拆分存到一個List<string>中，再轉(zhuǎn)化為字符串傳給存儲過程，很是麻煩。今天看了下SQL Server 2008的新特性，發(fā)現(xiàn)有表變量的使用，及其將DataTable作為參數(shù)的用法，就嘗試了一下，簡單談?wù)勑牡谩?
示例代碼下載

一、測試環(huán)境
1、Windows Server 2008 R2 DataCenter
2、Visual Studio 2008 Team System With SP1
3、SQL Server 2008 Enterprise Edition With SP1
由于是SQL Server 2008新特性，所以只能用2008。
二、測試概述
測試項目很簡單，就是添加新用戶

三、準備數(shù)據(jù)
1、建立數(shù)據(jù)庫、表、類型、存儲過程

復(fù)制代碼代碼如下:

 
IF NOT EXISTS(SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID('Users') AND OBJECTPROPERTY(id, N'IsUserTable') = 1) 
BEGIN 
CREATE TABLE dbo.Users 
( 
UserID INT IDENTITY(-1, -1) NOT NULL, 
UserName VARCHAR(20) NOT NULL, 
UserPass VARCHAR(20) NOT NULL, 
Sex BIT NULL, 
Age SMALLINT NULL, 
CONSTRAINT PK_Users_UserID PRIMARY KEY(UserID) 
) 
END 
IF NOT EXISTS(SELECT * FROM sys.table_types WHERE name = 'UserTable' AND is_user_defined = 1) 
BEGIN 
CREATE TYPE UserTable AS TABLE 
( 
UserName VARCHAR(20) NOT NULL, 
UserPass VARCHAR(20) NOT NULL, 
Sex BIT NULL, 
Age SMALLINT NULL 
) 
END 
GO 

復(fù)制代碼代碼如下:

 
IF EXISTS(SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID('sp_InsertSingleUser') AND OBJECTPROPERTY(id, N'IsProcedure') = 1) 
BEGIN 
DROP PROCEDURE dbo.sp_InsertSingleUser 
END 
GO 
CREATE PROCEDURE dbo.sp_InsertSingleUser 
( 
@User UserTable READONLY 
) 
AS 
SET XACT_ABORT ON 
BEGIN TRANSACTION 
INSERT INTO dbo.Users(UserName, UserPass, Sex, Age) 
SELECT UserName, UserPass, Sex, Age FROM @User 
COMMIT TRANSACTION 
SET XACT_ABORT OFF 
GO 

前臺搭建好表單，后臺主要是一個函數(shù)：

復(fù)制代碼代碼如下:

 
public void fnInsertSingleUser(DataTable v_dt) 
{ 
try 
{ 
SqlConnection cn = new SqlConnection(CONN); 
SqlCommand cmd = cn.CreateCommand(); 
cmd.CommandType = CommandType.StoredProcedure; 
cmd.CommandText = @"sp_InsertSingleUser"; 
SqlParameter p = cmd.Parameters.AddWithValue("@User", v_dt); 
10 
DataSet ds = new DataSet(); 
SqlDataAdapter da = new SqlDataAdapter(cmd); 
da.Fill(ds); 
} 
catch (Exception ex) 
{ 
throw ex; 
} 
} 