public class Test { private void TestGetRec()
{
//------取数据-----------
DataSet ds = DB.getRec("select * from customer");
this.dataGrid1.DataSource = ds.Tables[0]; } private void TestExeStore()
{
//---------执行存储过程范例---------
SqlParameter[] para = new SqlParameter[] {
new SqlParameter("@x2",SqlDbType.VarChar,255),
new SqlParameter("@x1",SqlDbType.Int,8),
new SqlParameter("@x3",SqlDbType.VarChar,255)
}; para[0].Direction = ParameterDirection.Output; para[1].Direction = ParameterDirection.ReturnValue; para[2].Direction = ParameterDirection.Input;
para[2].Value = "pppppppppppppppppppppppp"; //返回Command。
SqlCommand dbc= (SqlCommand)DB.ExecuteByStore("selectdata",para); //返回值
object o = dbc.Parameters["@x1"].Value;
object oo = dbc.Parameters["@x3"].Value; } private void TestExecuteWithTran()
{ //--------含有事务管理的执行更新语句-----------
DB.ExecuteWithTran("update customer set custname='浙江' where id=1 ");
} private void TestMulti()
{
string SQL_INSERT_HMD = "INSERT INTO SJ_HMD(UNAME,SJHM,SM) VALUES(:uname,:sjhm,:sm)";
string SQL_DELETE_HMD = "DELETE FROM SJ_HMD WHERE UNAME=:uname"; string PARAM_UNAME = "UNAME";
string PARAM_SJHM = "SJHM";
string PARAM_SM = "SM";
//---first parameter-----------
SqlParameter[] para = new SqlParameter[] {
new SqlParameter(PARAM_UNAME,SqlDbType.VarChar,50),
new SqlParameter(PARAM_SJHM,SqlDbType.VarChar,50),
new SqlParameter(PARAM_SM,SqlDbType.VarChar,255)
};
para[0].Value ="sss";
para[1].Value = "dddd";
para[2].Value = "uuuu";
//------------------------------- //-----second parameter-----------
SqlParameter[] para2 = new SqlParameter[]{ new SqlParameter(PARAM_UNAME,SqlDbType.VarChar,50)};
para2[0].Value = "7"; //-------------------------------
try
{
//-----在一个事务上执行多个语句-------
DB.BeginTran();
DB.ExeMultiPara(SQL_INSERT_HMD,para);
DB.ExeMultiPara(SQL_DELETE_HMD,para2);
DB.CommitTran();
}
catch(Exception ex)
{
DB.RollBackTran(); //回滚
throw new Exception(ex.ToString());
}
} private void TestExecuteSql()
{
//------无事务的更新语句----------
DB.ExecuteSql("update customer set custname='浙江' where id=2");
} private void TestExeWithPara()
{ //---------执行带参数的含事务插入语句---------
SqlParameter[] para = new SqlParameter[]{ new SqlParameter("param1",SqlDbType.VarChar)};
para[0].Value = "testdata";
DB.ExecuteWithParam("insert into customer values(@param1)",para);
} private void TestExeMulti()
{
try
{
//-----在一个事务上执行多个语句-------
DB.BeginTran();
DB.Execute("inser into customer values('testdata')");
DB.Execute("update customer set custname='updateData' where id=1");
DB.CommitTran();
}
catch(Exception ex)
{
DB.RollBackTran();
throw new Exception(ex.ToString());
}
} private void TestReturnReader()
{ //----------返回DataReader---------
SqlDataReader rdr = (SqlDataReader)DB.getDataByReader("select * from customer");
while(rdr.Read())
{
}
} private void TestGetDataByPara()
{
//----------含有参数的select --------------------
SqlParameter[] para = new SqlParameter[]{ new SqlParameter("@id",SqlDbType.Int,8)};
para[0].Value = 9;
DataSet ds = DB.getDataWithParam("select * from customer where id = @id",para);
this.dataGrid1.DataSource = ds.Tables[0];
} private void TestGetRecByStore()
{
//--------执行无参数的存储过程---------
DataSet ds = DB.getRecByStore("selectCustomer","customer",null); this.dataGrid1.DataSource = ds.Tables[0];
//----------执行有参数的存储过程-------------
SqlParameter[] para = new SqlParameter[]{ new SqlParameter("@id",SqlDbType.Int,8)};
para[0].Value = 9;
DataSet ds2 = DB.getRecByStore("selectCustomer","customer",para);
this.dataGrid1.DataSource = ds2.Tables[0]; } private void TestGetDataReader()
{
//----------执行无参数的过程，返回DataReader---------
SqlDataReader rdr = (SqlDataReader)DB.getReaderByStore("selectCustomer",null); while(rdr.Read())
{
//processing code
}
//----------执行有参数的过程，返回DataReader---------
SqlParameter[] para = new SqlParameter[]{ new SqlParameter("@id",SqlDbType.Int,8)};
para[0].Value = 9;
SqlDataReader rd = (SqlDataReader)DB.getReaderByStore("selectCustomer",para); while(rdr.Read())
{
//processing code
}
} } 
|
本类阅读TOP10