usingSystem;
usingSystem.Collections.Generic;
usingSystem.Linq;
usingSystem.Web;
usingSystem.Configuration;
usingSystem.Data.SqlClient;
usingSystem.Data;
///
///Database的摘要说明
///
publicclassDatabase
{
privatestringconnectionString=ConfigurationManager.ConnectionStrings["TCDBConnectionString"].ConnectionString;
privateSqlConnectioncon;
publicvoidCloseSQL()
{
con.Dispose();
con.Close();
con=null;
}
publicvoidOpenConnection()
{
if(con==null)
{
con=newSqlConnection(connectionString);
}
elseif(con.State==ConnectionState.Open)
{
return;
}
con.Open();
}
publicintExecuteSQL(stringsqlString,SqlParameter[]values)
{
OpenConnection();
SqlCommandcom=newSqlCommand(sqlString,con);
foreach(variteminvalues)
{
com.Parameters.Add(item);
}
returncom.ExecuteNonQuery();
}
publicintExecuteSQL(stringsqlString)
{
OpenConnection();
SqlCommandcom=newSqlCommand(sqlString,con);
returncom.ExecuteNonQuery();
}
publicboolIsExist(stringsqlString)
{
OpenConnection();
SqlCommandcom=newSqlCommand(sqlString,con);//命令对象
SqlDataReadersdr=com.ExecuteReader();
try
{
if(sdr.Read())
{
returntrue;
}
else
{
returnfalse;
}
}
catch(Exception)
{
throw;
}
finally{
sdr.Close();
}
}
publicSqlDataReaderIsExist(stringsqlString,SqlParameter[]values)
{
OpenConnection();
SqlCommandcom=newSqlCommand(sqlString,con);//命令对象
foreach(variteminvalues)
{
com.Parameters.Add(item);
}
SqlDataReaderdr=com.ExecuteReader();
returndr;
}
publicDataSetGetDataSet(stringsqlString)
{
OpenConnection();
SqlCommandcom=newSqlCommand(sqlString,con);
SqlDataAdapterada=newSqlDataAdapter(com);//数据适配器
DataSetds=newDataSet();
ada.Fill(ds);
returnds;
}
publicSqlDataReaderGetDataReader(stringsqlString)
{
OpenConnection();
SqlCommandcom=newSqlCommand(sqlString,con);
SqlDataReaderdr=com.ExecuteReader();
returndr;
}
publicintyzSQL(stringstrsql)
{
inti=0;
OpenConnection();
SqlCommandcomm=newSqlCommand(strsql,con);
if(comm.ExecuteScalar()!=null)
{
i=1;
}
con.Close();
returni;
}
publicintzxsql(stringstr)
{
OpenConnection();
SqlCommandcomm=newSqlCommand(str,con);
returncomm.ExecuteNonQuery();
}
publicDataSetGetSQL(stringstrsql)
{
OpenConnection();
SqlCommandcom=newSqlCommand(strsql,con);
DataSetds=newDataSet();
SqlDataAdaptersda=newSqlDataAdapter(com);
sda.Fill(ds);
CloseSQL();
returnds;
}
publicintUpSql(stringstrsql)
{
inti=0;
OpenConnection();
SqlCommandcomm=newSqlCommand(strsql,con);
if(comm.ExecuteNonQuery()==1)
{
i=1;
}
con.Close();
returni;
//openSQL();
//com=newSqlCommand(strsql,con);
//ds=newDataSet();
//sda=newSqlDataAdapter(com);
//SqlCommandBuilderscb=newSqlCommandBuilder(sda);
//returnsda;
}
} |
|
