2023年6月21日发(作者：)
C#操作MSSQL类⽇常⼯作经常操作数据库 于是写了这个本⼈经常操作MSSQL数据库的⼀个类，希望有朋友能⽤到，代码纯粹只⾯向⾃⼰的常⽤操作1 如果是 ⽤户 配置⽂件
[codes=c#]
[/codes]
2 JunvalMSSql的具体实现
[codes=c#]using System;
using ;
using ent;namespace Junval
{
//JunvalMSSql类 专⽤操作 SQL SERVER数据⽤户常⽤⽅法#region JunvalMSSql类 专⽤操作 SQL SERVER数据⽤户常⽤⽅法
/**////
/// JunvalMSSql 的摘要说明。
/// JunvalMSSql类 专⽤操作 SQL SERVER数据⽤户常⽤⽅法
/// 开发者: 徐忠威 Junval
/// 建类时间: 2007年2⽉25⽇
/// 开发平台: .NET 1.1 C#
///
public class JunvalMSSql
{
private string connString;//连接sql server 字符串
private string sqlString; //执⾏的sql语句/**////
/// 默认构造函数
/// 默认在中配置 add key="mssql" value="Server=127.0.0.1;UID=sa;PWD=;Database="
///
public JunvalMSSql()
{
//
// TODO: 在此处添加构造函数逻辑
//默认连接字符串以由webconfig决定
connString = tings["mssql"].ToString();
}/**////
/// mssql 连接字符串构造
///
/// sql server连接字符串
public JunvalMSSql(string connStr)
{
connString = connStr;
}/**////
/// 由需要执⾏的sql语句 与 sql server连接字符串构造成
///
/// 需要执⾏的sql语句
/// 连接sql server的字符串
public JunvalMSSql(string executeSql, string sqlConnStr)
{
connString = sqlConnStr;
sqlString = executeSql;
}/**////
/// 设置connString属性
///
public string ConnString
{
get
{ return connString;
}
set
{
connString = value;
}
}/**////
/// 设置sqlString属性
///
public string SqlString
{
get
{
return sqlString;
}
set
{
sqlString = value;
}
}/**////
/// 执⾏SQL语句 由ing属性设置
///
///
public string ExecuteSql()
{
string ls_ret ="";
SqlConnection Conn = new SqlConnection(connString);
try
{
();
}
catch(SqlException ex)
{
ls_ret = "(0)["+ng()+"]"+e;
goto
ErrEnd;
}
SqlTransaction myTrans = ransaction();
try
{
SqlCommand Cmd = new SqlCommand(sqlString,Conn,myTrans);
eNonQuery();
();
ls_ret = "1";
}
catch(SqlException ex)
{
ls_ret = "(-1)["+ng()+"]" + ng();
ck();}
finally
{
();
}
ErrEnd:
return ls_ret;
}
/**////
/// 执⾏带参数sql语句
///
/// 需要执⾏的sql语句
///
public string ExecuteSql(string excuteSql) {
ing = excuteSql;
return ExecuteSql();
}
/**////
/// 执⾏带参数的sql语句
///
/// sqlString中的参数
///
public string ExecuteSqlParms(SqlParameter[] Parms)
{
string ls_ret = "";
SqlConnection Conn = new SqlConnection(connString);
try
{
();
}
catch(SqlException ex)
{
ls_ret = "(0)["+ng()+"]"+e;
goto
ErrEnd;
}
SqlTransaction myTrans = ransaction();
try
{
SqlCommand Cmd = new SqlCommand(sqlString,Conn,myTrans);
if(Parms != null)
{
foreach(SqlParameter Paramter in Parms)
{
(Paramter);
}
}
eNonQuery();
();
ls_ret = "1";
}
catch(SqlException ex)
{
ls_ret = "(-1)["+ng()+"]"+e;
ck();
}
finally
{
();
}
ErrEnd:
return ls_ret;
}/**////
/// 执⾏带参数的sql语句
///
/// 执⾏的语句
/// 执⾏语句中的参数
///
public string ExecuteSqlParms(string executeSql, SqlParameter[] Parms)
{
ing = executeSql;
return ExecuteSqlParms(Parms);
}/**////
/// 执⾏多条sql语句
///
/// string[] sql语句数组
///
{
string ls_ret ="";
SqlConnection Conn = new SqlConnection(connString);
try
{
();
}
catch(SqlException ex)
{
ls_ret = "(0)["+ng()+"]"+e;
goto
ErrEnd;
}
SqlTransaction myTrans = ransaction();
try
{
SqlCommand Cmd = Command();
ction = myTrans;
if(Sqls != null)
{
foreach(string sql in Sqls)
{
dText = sql;
eNonQuery();
}
}
();
ls_ret = "1";
}
catch(SqlException ex)
{
ls_ret = "(-1)["+ng()+"]"+e;
ck();
}
finally
{
();
}
ErrEnd:
return ls_ret;
}/**////
/// 执⾏⽆参数的过程
///
///
public string ExecuteProcedure()
{
string ls_ret ="";
SqlConnection Conn = new SqlConnection(connString);
try
{
();
}
catch(SqlException ex)
{
ls_ret ="(0)["+ng()+"]"+ e;
goto
ErrEnd;
}
SqlTransaction myTrans = ransaction();
try
{
SqlCommand Cmd = new SqlCommand(sqlString,Conn,myTrans);
dType = Procedure;
eNonQuery();
(); ls_ret = "1";
}
catch(SqlException ex)
{
ls_ret = "(-1)["+ng()+"]"+e;
ck();
}
finally
{
();
}
ErrEnd:
return ls_ret;
}
/**////
/// 执⾏⽆参数过程
///
/// 过程名字
///
public string ExecuteProcedure(string ProcedureName)
{
ing = ProcedureName;
return ExecuteProcedure();
}/**////
/// 返回⼀个DataSet对象,默认返回Table[0]名字为"MyData"
///
///
public DataSet GetDataSet()
{
DataSet RetDs = new DataSet();
SqlConnection Conn = new SqlConnection(connString);
SqlDataAdapter Adapter = new SqlDataAdapter(sqlString,Conn);
try
{
();
(RetDs,"MyData");
}
catch
{
RetDs = null;
}
finally
{
();
}
return RetDs;
}/**////
/// 返回⼀个DataSet对象,默认返回Table[0]名字为"MyData"
///
/// 查询dataSet的sql语句
///
public DataSet GetDataSet(string executeSql)
{
sqlString = executeSql;
return GetDataSet();
}
/**////
/// 返回⼀个DataSet对象,table[0] 为 "MyData"
///
/// 执⾏查询的sql语句
/// 连接sql server字符串
///
public DataSet GetDataSet(string executeSql,string sqlConnString)
{ sqlString = executeSql;
connString = sqlConnString;
return GetDataSet();
}/**////
/// 返回⼀个SqlDataReader对象
///
///
public SqlDataReader GetDataReader()
{
SqlDataReader RetDataReader;
SqlConnection Conn = new SqlConnection(connString);
try
{
();
SqlCommand Cmd = new SqlCommand(sqlString,Conn);
RetDataReader = eReader();
}
catch
{
RetDataReader = null;
}
finally
{
();
}
return RetDataReader;
}/**////
/// 返回⼀个SqlDataReader对象
///
/// 执⾏查询的sql语句
///
public SqlDataReader GetDataReader(string selectSql)
{
sqlString = selectSql;
return GetDataReader();
}
/**////
/// 返回⼀个SqlDataReader对象
///
/// 执⾏查询的sql语句
/// sql server连接字符串
///
public SqlDataReader GetDataReader(string selectSql,string sqlConnString)
{
sqlString = selectSql;
connString = sqlConnString;
return GetDataReader();
}
/**////
/// 返回⼀个SqlConnection对象
///
///
public SqlConnection Connection()
{
SqlConnection Conn = new SqlConnection(connString);
return Conn;
}
}}
[/codes]
2023年6月21日发(作者：)
C#操作MSSQL类⽇常⼯作经常操作数据库 于是写了这个本⼈经常操作MSSQL数据库的⼀个类，希望有朋友能⽤到，代码纯粹只⾯向⾃⼰的常⽤操作1 如果是 ⽤户 配置⽂件
[codes=c#]
[/codes]
2 JunvalMSSql的具体实现
[codes=c#]using System;
using ;
using ent;namespace Junval
{
//JunvalMSSql类 专⽤操作 SQL SERVER数据⽤户常⽤⽅法#region JunvalMSSql类 专⽤操作 SQL SERVER数据⽤户常⽤⽅法
/**////
/// JunvalMSSql 的摘要说明。
/// JunvalMSSql类 专⽤操作 SQL SERVER数据⽤户常⽤⽅法
/// 开发者: 徐忠威 Junval
/// 建类时间: 2007年2⽉25⽇
/// 开发平台: .NET 1.1 C#
///
public class JunvalMSSql
{
private string connString;//连接sql server 字符串
private string sqlString; //执⾏的sql语句/**////
/// 默认构造函数
/// 默认在中配置 add key="mssql" value="Server=127.0.0.1;UID=sa;PWD=;Database="
///
public JunvalMSSql()
{
//
// TODO: 在此处添加构造函数逻辑
//默认连接字符串以由webconfig决定
connString = tings["mssql"].ToString();
}/**////
/// mssql 连接字符串构造
///
/// sql server连接字符串
public JunvalMSSql(string connStr)
{
connString = connStr;
}/**////
/// 由需要执⾏的sql语句 与 sql server连接字符串构造成
///
/// 需要执⾏的sql语句
/// 连接sql server的字符串
public JunvalMSSql(string executeSql, string sqlConnStr)
{
connString = sqlConnStr;
sqlString = executeSql;
}/**////
/// 设置connString属性
///
public string ConnString
{
get
{ return connString;
}
set
{
connString = value;
}
}/**////
/// 设置sqlString属性
///
public string SqlString
{
get
{
return sqlString;
}
set
{
sqlString = value;
}
}/**////
/// 执⾏SQL语句 由ing属性设置
///
///
public string ExecuteSql()
{
string ls_ret ="";
SqlConnection Conn = new SqlConnection(connString);
try
{
();
}
catch(SqlException ex)
{
ls_ret = "(0)["+ng()+"]"+e;
goto
ErrEnd;
}
SqlTransaction myTrans = ransaction();
try
{
SqlCommand Cmd = new SqlCommand(sqlString,Conn,myTrans);
eNonQuery();
();
ls_ret = "1";
}
catch(SqlException ex)
{
ls_ret = "(-1)["+ng()+"]" + ng();
ck();}
finally
{
();
}
ErrEnd:
return ls_ret;
}
/**////
/// 执⾏带参数sql语句
///
/// 需要执⾏的sql语句
///
public string ExecuteSql(string excuteSql) {
ing = excuteSql;
return ExecuteSql();
}
/**////
/// 执⾏带参数的sql语句
///
/// sqlString中的参数
///
public string ExecuteSqlParms(SqlParameter[] Parms)
{
string ls_ret = "";
SqlConnection Conn = new SqlConnection(connString);
try
{
();
}
catch(SqlException ex)
{
ls_ret = "(0)["+ng()+"]"+e;
goto
ErrEnd;
}
SqlTransaction myTrans = ransaction();
try
{
SqlCommand Cmd = new SqlCommand(sqlString,Conn,myTrans);
if(Parms != null)
{
foreach(SqlParameter Paramter in Parms)
{
(Paramter);
}
}
eNonQuery();
();
ls_ret = "1";
}
catch(SqlException ex)
{
ls_ret = "(-1)["+ng()+"]"+e;
ck();
}
finally
{
();
}
ErrEnd:
return ls_ret;
}/**////
/// 执⾏带参数的sql语句
///
/// 执⾏的语句
/// 执⾏语句中的参数
///
public string ExecuteSqlParms(string executeSql, SqlParameter[] Parms)
{
ing = executeSql;
return ExecuteSqlParms(Parms);
}/**////
/// 执⾏多条sql语句
///
/// string[] sql语句数组
///
{
string ls_ret ="";
SqlConnection Conn = new SqlConnection(connString);
try
{
();
}
catch(SqlException ex)
{
ls_ret = "(0)["+ng()+"]"+e;
goto
ErrEnd;
}
SqlTransaction myTrans = ransaction();
try
{
SqlCommand Cmd = Command();
ction = myTrans;
if(Sqls != null)
{
foreach(string sql in Sqls)
{
dText = sql;
eNonQuery();
}
}
();
ls_ret = "1";
}
catch(SqlException ex)
{
ls_ret = "(-1)["+ng()+"]"+e;
ck();
}
finally
{
();
}
ErrEnd:
return ls_ret;
}/**////
/// 执⾏⽆参数的过程
///
///
public string ExecuteProcedure()
{
string ls_ret ="";
SqlConnection Conn = new SqlConnection(connString);
try
{
();
}
catch(SqlException ex)
{
ls_ret ="(0)["+ng()+"]"+ e;
goto
ErrEnd;
}
SqlTransaction myTrans = ransaction();
try
{
SqlCommand Cmd = new SqlCommand(sqlString,Conn,myTrans);
dType = Procedure;
eNonQuery();
(); ls_ret = "1";
}
catch(SqlException ex)
{
ls_ret = "(-1)["+ng()+"]"+e;
ck();
}
finally
{
();
}
ErrEnd:
return ls_ret;
}
/**////
/// 执⾏⽆参数过程
///
/// 过程名字
///
public string ExecuteProcedure(string ProcedureName)
{
ing = ProcedureName;
return ExecuteProcedure();
}/**////
/// 返回⼀个DataSet对象,默认返回Table[0]名字为"MyData"
///
///
public DataSet GetDataSet()
{
DataSet RetDs = new DataSet();
SqlConnection Conn = new SqlConnection(connString);
SqlDataAdapter Adapter = new SqlDataAdapter(sqlString,Conn);
try
{
();
(RetDs,"MyData");
}
catch
{
RetDs = null;
}
finally
{
();
}
return RetDs;
}/**////
/// 返回⼀个DataSet对象,默认返回Table[0]名字为"MyData"
///
/// 查询dataSet的sql语句
///
public DataSet GetDataSet(string executeSql)
{
sqlString = executeSql;
return GetDataSet();
}
/**////
/// 返回⼀个DataSet对象,table[0] 为 "MyData"
///
/// 执⾏查询的sql语句
/// 连接sql server字符串
///
public DataSet GetDataSet(string executeSql,string sqlConnString)
{ sqlString = executeSql;
connString = sqlConnString;
return GetDataSet();
}/**////
/// 返回⼀个SqlDataReader对象
///
///
public SqlDataReader GetDataReader()
{
SqlDataReader RetDataReader;
SqlConnection Conn = new SqlConnection(connString);
try
{
();
SqlCommand Cmd = new SqlCommand(sqlString,Conn);
RetDataReader = eReader();
}
catch
{
RetDataReader = null;
}
finally
{
();
}
return RetDataReader;
}/**////
/// 返回⼀个SqlDataReader对象
///
/// 执⾏查询的sql语句
///
public SqlDataReader GetDataReader(string selectSql)
{
sqlString = selectSql;
return GetDataReader();
}
/**////
/// 返回⼀个SqlDataReader对象
///
/// 执⾏查询的sql语句
/// sql server连接字符串
///
public SqlDataReader GetDataReader(string selectSql,string sqlConnString)
{
sqlString = selectSql;
connString = sqlConnString;
return GetDataReader();
}
/**////
/// 返回⼀个SqlConnection对象
///
///
public SqlConnection Connection()
{
SqlConnection Conn = new SqlConnection(connString);
return Conn;
}
}}
[/codes]
发布评论