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
}
}
}
