《.NET实例开发》实验指导书 - 图文

///

/// /// /// /// ///

public static SqlParameter GetParameter(String paramName, SqlDbType paramType, Int32

paramSize, String ColName) {

SqlParameter param = new SqlParameter(paramName, paramType, paramSize, ColName); return param; }

///

/// /// /// /// ///

public static SqlParameter GetParameter(String paramName, SqlDbType paramType, Object

paramValue) {

SqlParameter param = new SqlParameter(paramName, paramType); param.Value = paramValue; return param; }

///

/// /// ///

public static int ExecuteSql(String Sqlstr, SqlParameter[] param) {

String ConnStr = SQLDbHelper.GetSqlConnection();

using (SqlConnection conn = new SqlConnection(ConnStr)) {

SqlCommand cmd = new SqlCommand(); cmd.Connection = conn; cmd.CommandText = Sqlstr;

cmd.Parameters.AddRange(param);

32

conn.Open();

cmd.ExecuteNonQuery(); conn.Close(); return 1; } }

///

/// ///

public static DataTable ExecuteDt(String Sqlstr) {

String ConnStr = SQLDbHelper.GetSqlConnection();

using (SqlConnection conn = new SqlConnection(ConnStr)) {

SqlDataAdapter da = new SqlDataAdapter(Sqlstr, conn); DataTable dt = new DataTable(); conn.Open(); da.Fill(dt); conn.Close(); return dt; } }

///

/// /// ///

public static DataTable ExecuteDt(String Sqlstr, SqlParameter[] param) {

String ConnStr = SQLDbHelper.GetSqlConnection();

using (SqlConnection conn = new SqlConnection(ConnStr)) {

DataTable dt = new DataTable();

SqlDataAdapter da = new SqlDataAdapter();

SqlCommand cmd = new SqlCommand(Sqlstr, conn); cmd.Connection = conn;

cmd.Parameters.AddRange(param); da.SelectCommand = cmd; conn.Open();

33

da.Fill(dt); conn.Close(); return dt; } }

///

/// /// ///

public static Int32 ExecuteSqls(String[] Sqlstr, List param) {

String ConnStr = SQLDbHelper.GetSqlConnection();

using (SqlConnection conn = new SqlConnection(ConnStr)) {

SqlCommand cmd = new SqlCommand(); SqlTransaction tran = null; cmd.Transaction = tran; try {

conn.Open();

tran = conn.BeginTransaction(); cmd.Connection = conn; cmd.Transaction = tran;

Int32 count = Sqlstr.Length;

for (Int32 i = 0; i < count; i ++ ) {

cmd.CommandText = Sqlstr[i];

cmd.Parameters.AddRange(param[i]); cmd.ExecuteNonQuery(); }

tran.Commit(); return 1; } catch {

tran.Rollback(); return 0; }

finally

34

{

cmd.Dispose(); conn.Close(); } } } } }

最后，右单击项目名“DBUtility”,在快捷菜单中单击“生成”菜单，编译生成该类库项目，若

成功，则自动生成程序集DBUtility.dll，保存在项目目录的bin\\Debug目录下。 （2）为IDAL项目添加接口文件

在IDAL项目中添加接口文件Iuserinfo.cs，首先将该接口的访问属性改为“public”，将命名空间改为“CSharpStudy.IDAL”，再添加代码，最后其完整内容如下： using System;

using System.Collections.Generic; using System.Text;

namespace CSharpStudy.IDAL {

public interface Iuserinfo {

bool validUser(string username,string password); } }

右单击项目名“IDAL”,在快捷菜单中单击“生成”菜单，编译生成该类库项目，若成功，则自动

生成程序集IDAL.dll，保存在项目目录的bin\\Debug目录下。 （3）为DALFactory项目添加类文件

在项目DALFactory中添加类文件DataAccess.cs，首先在文件的开始部分添加以下命名空间的引

用：

using System.Configuration; using System.Reflection;

然后将DataAccess类的访问属性定义为“public”，将命名空间改为“CSharpStudy.DALFactory”，

再添加代码，最后类文件DataAccess.cs完整内容如下： using System;

using System.Collections.Generic; using System.Text;

using System.Configuration; using System.Reflection;

namespace CSharpStudy.DALFactory {

public class DataAccess {

//以下是连接Access数据库的命名空间路径 //private static readonly string path =

35