C#數據訪問層1.查詢數據庫中的數據，返回一個datatable

C#數據訪問層2.執行一條SQL語句已重載

using System;  
using System.Data;  
using NUnit.Framework;  
using CodeFilemanger.Project;  
using System.Data.SqlClient;  
using System.Configuration;  
namespace OperatorDB  
{  
 
///   
/// Class1 的摘要說明。  
///   
[NUnit.Framework.TestFixture]  
public class OperatorDB   
{   
private static string strCon = ConfigurationSettings.AppSettings["ConnectionString"] ;   
private int ModuleId = 1;  
public static string ConnectionString   
{   
get   
{   
return strCon;   
}   
set   
{   
strCon = value;   
}   
}   
 
#region "初始化"   
[NUnit.Framework.TestFixtureSetUp]  
public void Register_Module()  
{   
string ModuleName = "OperatorDB";  
string ModuleAuthor = "MYM";  
string ModuleDescribe = "數據訪問模塊";  
string CreateDatetime = "2003-5-30";  
ModuleId = Project.InsertModule( ModuleName, ModuleAuthor, ModuleDescribe, CreateDatetime) ;   
}  
[Test]  
public void Register_Method_SelectData()  
{  
string MethodName = "SelectData";  
string MethodAuthor = "MYM";  
string MethodCreateDateTime = "2005-3-30";  
string MethodParaMeters ="ParaMeters(string SqlCommandText, System.Data.DataTable Dt, bool RowsClearr)";  
string MethodReturn = "bool";  
string MethodCall = "" ;  
string MethodDescribe = "查詢數據庫中的數據，返回一個datatable";  
Project.InsertMethod(MethodName,MethodAuthor,MethodCreateDateTime,MethodParaMeters,MethodReturn,MethodCall,MethodDescribe,ModuleId);   
}  
[Test]  
public void Register_Method_ExecuteSql()  
{  
string MethodName = "ExecuteSql";  
string MethodAuthor = "MYM";  
string MethodCreateDateTime = "2005-3-30";  
string MethodParaMeters ="ParaMeters(string SqlCommandText)";  
string MethodReturn = "int";  
string MethodCall = "" ;  
string MethodDescribe = "執行一條SQL語句";  
Project.InsertMethod(MethodName,MethodAuthor,MethodCreateDateTime,MethodParaMeters,MethodReturn,MethodCall,MethodDescribe,ModuleId);   
}  
[Test]  
public void Register_Method_SerialNumber()  
{  
string MethodName = "SerialNumber";  
string MethodAuthor = "MYM";  
string MethodCreateDateTime = "2005-3-30";  
string MethodParaMeters ="ParaMeters(int index, System.Data.DataTable dt)";  
string MethodReturn = "void";  
string MethodCall = "" ;  
string MethodDescribe = "給表的指定列添加序號";  
Project.InsertMethod(MethodName,MethodAuthor,MethodCreateDateTime,MethodParaMeters,MethodReturn,MethodCall,MethodDescribe,ModuleId);   
}  
 
#endregion   
public static bool SelectData(string SqlCommandText, System.Data.DataTable Dt, bool RowsClearr)   
{   
strCon = ConfigurationSettings.AppSettings["ConnectionString"];   
bool ret = true;   
if (SqlCommandText != "")   
{   
if (RowsClearr)   
{   
if (Dt.Rows.Count > 0)  
{  
Dt.Rows.Clear();   
}  
 
}   
SqlConnection cn = new SqlConnection(strCon);   
SqlDataAdapter da = new SqlDataAdapter(SqlCommandText, cn);   
try   
{   
cn.Open();   
da.Fill(Dt);   
}   
catch (System.Exception ex)   
{   
ExceptionHand exc = new ExceptionHand(ex);   
exc.DisplayErrorMessager("OperatorDB","SelectData",SqlCommandText);   
ret = false;   
}   
if (cn.State == ConnectionState.Open)   
{   
cn.Close();   
}   
da.Dispose();   
}   
else   
{   
ret = false;   
}   
return ret;   
}   
public static int ExecuteSql(string SqlCommandText)   
{   
int ID = 0;   
strCon = ConfigurationSettings.AppSettings["ConnectionString"];   
if (SqlCommandText != "")   
{   
SqlConnection cn = new SqlConnection(strCon);   
SqlCommand cm = new SqlCommand(SqlCommandText, cn);   
try   
{   
cn.Open();  
ID = Convert.ToInt32(cm.ExecuteScalar());  
}   
catch (System.Exception ex)   
{   
cn.Close();  
ExceptionHand exc = new ExceptionHand(ex);   
exc.DisplayErrorMessager("OperatorDB","ExecuteSql",SqlCommandText);   
ID = -1;   
}   
 
if (cn.State == ConnectionState.Open)   
{   
cn.Close();   
}   
cm.Dispose();   
}   
return ID;   
}   
public static int ExecuteSql(SqlCommand Cm)   
{   
int ID = 0;   
strCon = ConfigurationSettings.AppSettings["ConnectionString"];   
SqlConnection cn = new SqlConnection(strCon);   
try   
{   
cn.Open();   
Cm.Connection = cn;  
ID = Convert.ToInt32(Cm.ExecuteScalar());   
}   
catch (System.Exception ex)   
{   
cn.Close();  
ExceptionHand exc = new ExceptionHand(ex);   
exc.DisplayErrorMessager("OperatorDB","ExecuteSql",Cm.CommandText);   
ID = -1;   
}   
 
if (cn.State == ConnectionState.Open)   
{   
cn.Close();   
}   
Cm.Dispose();   
 
return ID;   
}   
public static void SerialNumber(int index, System.Data.DataTable dt)   
{   
for (int i = 0; i <= dt.Rows.Count - 1; i++)   
{   
dt.Rows[i][index] = i + 1;   
}   
}   
public static void SetSqlCommandValues(SqlCommand Com,DataTable Dt,int Index,int StartIndex)  
{  
int i;  
for (i=StartIndex;i{  
Com.Parameters.Add("@" + Dt.Columns[i].ColumnName,Dt.Rows[Index][i]);  
}  
}   
}  
} 

C#數據訪問層的相關知識就介紹到這里。

【編輯推薦】

1. C#結構體的特點淺析
2. 介紹C#窗體拖動事件
3. C#讀取Excel遇到無法讀取的解決方法
4. 概述C#.NET操作XML
5. C#基礎概念學習筆記