數據庫訪問類(Query,Insert,Update,Delete)

數據庫訪問類:SQLHelp(原創,轉載請注明出處)

1.接口類:IDAL.cs

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

namespace DB.SQLHelp.DAL
{
public interface IDAL
{
bool isExist(string SQL);

bool isExist(string SQL, dsParm.ParameterDataTable ParmDataTable);

bool GetValue(string SQL, string[] txtValue, int[] txtIndex);

bool GetValue(string SQL, string[] txtValue, int[] txtIndex, dsParm.ParameterDataTable ParmDataTable);

DataTable GetDataTable(string SQL);

DataTable GetDataTable(string SQL, dsParm.ParameterDataTable ParmDataTable);

DataTable GetDataTable(string SQL, string spName, int iPageSize, int iPageIndex, out int iTotalCount, out int iTotalPage);

int ExecuteSQL(string SQL);

int ExecuteSQL(string SQL, dsParm.ParameterDataTable ParmDataTable);

int ExecuteSQL(string[] SQL);

int ExecuteSQL(string[] SQL, dsParm.ParameterDataTable[] ParmDataTable);

int ExecuteProcedurs(string spName);
}
}

2.實現接口類:分成OleDBDAL.cs,OracleDAL.cs,SQLDAL.cs

略

3.選擇數據庫類型:DALFactory.cs

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

namespace DB.SQLHelp.DAL
{
public class DALFactory
{
private static readonly string dalType = ConfigurationManager.AppSettings["DAL"];
public static IDAL Create(string conn)
{
IDAL ret = null;
switch (dalType)
{
case "SQLDAL":
ret = new SQLDAL(conn);
break;
case "OracleDAL":
ret = new OracleDAL(conn);
break;
case "OleDbDAL":
ret = new OleDbDAL(conn);
break;
}
return ret;
}
}
}

4.調用方法類:BLLDAL.cs

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

namespace DB.SQLHelp.DAL
{
public class BLLDAL
{
string conn;

public BLLDAL(string _conn)
{
conn = _conn;
}

public bool isExist(string SQL)
{
IDAL dal = DALFactory.Create(conn);
return dal.isExist(SQL);
}

public bool isExist(string SQL, dsParm.ParameterDataTable ParmDataTable)
{
IDAL dal = DALFactory.Create(conn);
return dal.isExist(SQL, ParmDataTable);
}

public bool GetValue(string SQL, string[] txtValue, int[] txtIndex)
{
IDAL dal = DALFactory.Create(conn);
return dal.GetValue(SQL, txtValue, txtIndex);
}

public bool GetValue(string SQL, string[] txtValue, int[] txtIndex, dsParm.ParameterDataTable ParmDataTable)
{
IDAL dal = DALFactory.Create(conn);
return dal.GetValue(SQL, txtValue, txtIndex, ParmDataTable);
}

public DataTable GetDataTable(string SQL)
{
IDAL dal = DALFactory.Create(conn);
return dal.GetDataTable(SQL);
}

public DataTable GetDataTable(string SQL, dsParm.ParameterDataTable ParmDataTable)
{
IDAL dal = DALFactory.Create(conn);
return dal.GetDataTable(SQL, ParmDataTable);
}

public DataTable GetDataTable(string SQL, string spName, int iPageSize, int iPageIndex, out int iTotalCount, out int iTotalPage)
{
IDAL dal = DALFactory.Create(conn);
return dal.GetDataTable(SQL, spName, iPageSize, iPageIndex, out iTotalCount, out iTotalPage);
}

public int ExecuteSQL(string SQL)
{
IDAL dal = DALFactory.Create(conn);
return dal.ExecuteSQL(SQL);
}

public int ExecuteSQL(string SQL,dsParm.ParameterDataTable ParmDataTable)
{
IDAL dal = DALFactory.Create(conn);
return dal.ExecuteSQL(SQL,ParmDataTable);
}

public int ExecuteSQL(string[] SQL)
{
IDAL dal = DALFactory.Create(conn);
return dal.ExecuteSQL(SQL);
}

public int ExecuteSQL(string[] SQL, dsParm.ParameterDataTable[] ParmDataTable)
{
IDAL dal = DALFactory.Create(conn);
return dal.ExecuteSQL(SQL, ParmDataTable);
}

public int ExecuteProcedurs(string spName)
{
IDAL dal = DALFactory.Create(conn);
return dal.ExecuteSQL(spName);
}
}
}