accessdbhelper写法.docx
《accessdbhelper写法.docx》由会员分享，可在线阅读，更多相关《accessdbhelper写法.docx（13页珍藏版）》请在冰点文库上搜索。
accessdbhelper写法
publicclassDBAccess/*DBAccess*/
{
stringconStr;
OleDbConnectionconnection;
System.Data.OleDb.OleDbCommandcommand;
System.Data.OleDb.OleDbDataAdapterdataAdapter;
System.Data.OleDb.OleDbDataReaderdataReader;
publicDBAccess/*DBAccess*/（）
{
this.conStr=ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
}
publicDBAccess/*DBAccess*/（stringconstr）
{
this.conStr=ConfigurationManager.ConnectionStrings[constr].ConnectionString;
}
法兰厂家
弯头厂家
螺旋管
///
///执行sql语句
///
///要执行的sql语句
///
publicboolRunSql（stringsql）
{
try
{
connection=newSystem.Data.OleDb.OleDbConnection（conStr）;
connection.Open（）;
command=newSystem.Data.OleDb.OleDbCommand（sql,connection）;
intcount=command.ExecuteNonQuery（）;
connection.Close（）;
if（count>0）
{
returntrue;
}
elsereturnfalse;
}
catch（Exceptionex）
{
returnfalse;
}
}
///
///简单删除方法
///
///要删除记录的对应id
///要删除记录所在表对应的实体类的Type
///
publicbooldel（intid,Typetype）
{
stringsql=string.Format（"deletefrom{0}whereid={1}",type.Name,id）;
returnthis.RunSql（sql）;
}
///
///执行带参数的sql语句
///
///
///
///
///
publicboolRunSql（stringsql,System.Data.OleDb.OleDbParameter[]parameters,refstringerror）
{
try
{
connection=newSystem.Data.OleDb.OleDbConnection（conStr）;
connection.Open（）;
command=newSystem.Data.OleDb.OleDbCommand（）;
command.CommandText=sql;
command.Connection=connection;
command.Parameters.AddRange（parameters）;
intcount=command.ExecuteNonQuery（）;
connection.Close（）;
if（count>0）
{
returntrue;
}
elsereturnfalse;
}
catch（Exceptionex）
{
error=ex.Message;
Console.WriteLine（ex.Message）;
returnfalse;
}
网络机柜
地面防腐
}
///
///通用单表查询方法
///
///查询sql
///要查询的表名
///
publicDataTableSelect（stringsql,stringtableName）
{
connection=newSystem.Data.OleDb.OleDbConnection（conStr）;
dataAdapter=newSystem.Data.OleDb.OleDbDataAdapter（sql,connection）;
DataSetdataSet=newDataSet（）;
dataAdapter.Fill（dataSet,tableName）;
foreach（DataRowrowindataSet.Tables[0].Rows）
{
Console.WriteLine（"{0},{1}",row[0],row[1]）;
}
returndataSet.Tables[tableName];
}
///
///通用查询方法
///
///要查询的数据对应的泛型类型
///查询sql语句
///sql参数数组
///指定泛型类型的集合
publicListSelect（stringsql,System.Data.OleDb.OleDbParameter[]parameters）
{
Typetype=typeof（T）;
connection=newSystem.Data.OleDb.OleDbConnection（conStr）;
connection.Open（）;
command=newSystem.Data.OleDb.OleDbCommand（）;
command.CommandTimeout=180;
command.CommandText=sql;
command.Connection=connection;
command.Parameters.AddRange（parameters）;
dataReader=command.ExecuteReader（）;
Listlist=newList（）;
string[]fields=newstring[dataReader.FieldCount];
for（inti=0;i{
fields[i]=dataReader.GetName（i）;
}
while（dataReader.Read（））
{
PropertyInfo[]pros=type.GetProperties（）;
Objectobj=Activator.CreateInstance（type）;
foreach（stringstrinfields）
{
foreach（PropertyInfopropertyinpros）
{
if（str.ToLower（）==property.Name.ToLower（））
{
if（!
Convert.IsDBNull（dataReader[str]））
{
property.SetValue（obj,dataReader[str],null）;
}
Console.WriteLine（property.GetValue（obj,null））;
break;
}
}
}
list.Add（（（T）obj））;
}
dataReader.Close（）;
connection.Close（）;
if（list.Count==0）
{
returnnull;
}
returnlist;
}
///
///通用查询方法
///
///要查询的数据对应的泛型类型
///查询sql语句
///指定泛型类型的集合
publicListSelect（stringsql）
{
Typetype=typeof（T）;
connection=newSystem.Data.OleDb.OleDbConnection（conStr）;
connection.Open（）;
command=newSystem.Data.OleDb.OleDbCommand（sql,connection）;
dataReader=command.ExecuteReader（）;
Listlist=newList（）;
string[]fields=newstring[dataReader.FieldCount];
for（inti=0;i{
fields[i]=dataReader.GetName（i）;
}
while（dataReader.Read（））
{
PropertyInfo[]pros=type.GetProperties（）;
Objectobj=Activator.CreateInstance（type）;
foreach（stringstrinfields）
{
foreach（PropertyInfopropertyinpros）
{
if（str.ToLower（）==property.Name.ToLower（））
{
if（!
Convert.IsDBNull（dataReader[str]））
{
property.SetValue（obj,dataReader[str],null）;
}
Console.WriteLine（property.GetValue（obj,null））;
break;
}
}
}
list.Add（（（T）obj））;
}
dataReader.Close（）;
connection.Close（）;
if（list.Count==0）
{
returnnull;
}
returnlist;
}
///
///通用添加方法
///
///不能出现在insert中的字段组成的字符串集合
///需要添加的实体类对象
///
publicboolCurrencyAdd（Listidentity,objectobj）
{
for（intj=0;j{
identity[j]=identity[j].ToLower（）;
}
Typetype=obj.GetType（）;
PropertyInfo[]propertyInfos=type.GetProperties（）;
ListparameterList=newList（）;
stringcolName=string.Empty;
stringval=string.Empty;
foreach（PropertyInfoproinpropertyInfos）
{
objectproValue=type.InvokeMember（pro.Name,BindingFlags.GetProperty,null,obj,null）;
//System.Console.WriteLine（proValue.ToString（））;
stringname=pro.Name;
stringf=name.Substring（0,1）.ToLower（）;
name=f+name.Substring
（1）;
if（!
identity.Contains（pro.Name.ToLower（）））
{
if（proValue!
=null）
{
colName+="["+name+"],";
val+="@"+name+",";
if（proValue.GetType（）==typeof（DateTime））
{
System.Data.OleDb.OleDbParameteraaa=newOleDbParameter（"@"+name,System.Data.OleDb.OleDbType.Date）;
aaa.Value=proValue;
parameterList.Add（aaa）;
}
else
{
parameterList.Add（newSystem.Data.OleDb.OleDbParameter（"@"+name,proValue））;
}
}
}
}
System.Data.OleDb.OleDbParameter[]sqlParameters=newSystem.Data.OleDb.OleDbParameter[parameterList.Count];
parameterList.CopyTo（sqlParameters）;
colName=colName.Substring（0,colName.Length-1）;
val=val.Substring（0,val.Length-1）;
stringsql="insertinto["+type.Name+"]（"+colName+"）values（"+val+"）";
stringabc="";
returnthis.RunSql（sql,sqlParameters,refabc）;
}
///
///通用添加方法
///
///不能出现在insert中的字段组成的字符串集合
///需要添加的实体类对象
///
publicboolCurrencyAdd（Listidentity,objectobj,refstringerror）
{
for（intj=0;j{
identity[j]=identity[j].ToLower（）;
}
Typetype=obj.GetType（）;
PropertyInfo[]propertyInfos=type.GetProperties（）;
ListparameterList=newList（）;
stringcolName=string.Empty;
stringval=string.Empty;
foreach（PropertyInfoproinpropertyInfos）
{
objectproValue=type.InvokeMember（pro.Name,BindingFlags.GetProperty,null,obj,null）;
//System.Console.WriteLine（proValue.ToString（））;
stringname=pro.Name;
stringf=name.Substring（0,1）.ToLower（）;
name=f+name.Substring
（1）;
if（!
identity.Contains（pro.Name.ToLower（）））
{
if（proValue!
=null）
{
colName+="["+name+"],";
val+="@"+name+",";
if（proValue.GetType（）==typeof（DateTime））
{
System.Data.OleDb.OleDbParameteraaa=newOleDbParameter（"@"+name,System.Data.OleDb.OleDbType.Date）;
aaa.Value=proValue;
parameterList.Add（aaa）;
}
else
{
parameterList.Add（newSystem.Data.OleDb.OleDbParameter（"@"+name,proValue））;
}
}
}
}
System.Data.OleDb.OleDbParameter[]sqlParameters=newSystem.Data.OleDb.OleDbParameter[parameterList.Count];
parameterList.CopyTo（sqlParameters）;
colName=colName.Substring（0,colName.Length-1）;
val=val.Substring（0,val.Length-1）;
stringsql="insertinto["+type.Name+"]（"+colName+"）values（"+val+"）";
stringabc="";
returnthis.RunSql（sql,sqlParameters,referror）;
}
}
升级会员 