PetaPoco 的查询操作
public IEnumerable<T> GetAll(string sqlString, object[] obj)
{
try
{
IEnumerable<T> target;
using (PetaPoco.Database db=new PetaPoco.Database (DbConfig.ConnectionString))
{
target= db.Fetch<T>(sqlString, obj);
}
return target;
}
catch (Exception ep)
{
// 系统错误日志 级别： 严重错误
return null;
}
}
public IEnumerable<T> GetAll(string sqlString)
{
try
{
IEnumerable<T> target;
using (PetaPoco.Database db = new PetaPoco.Database(DbConfig.ConnectionString))
{
target = db.Fetch<T>(sqlString);
} return target;
}
catch (Exception ep)
{
// 系统错误日志 级别： 严重错误
return null;
}
}
public T Get(string sqlString, object[] obj)
{
try
{
T target;
using (PetaPoco.Database db = new PetaPoco.Database(DbConfig.ConnectionString))
{
target = db.SingleOrDefault<T>(sqlString, obj);
}
return target;
}
catch (Exception ep)
{
return null;
}
}
使用 PetaPoco 时行分页查询
public PetaPoco.Page<T> GetPageData(int pageIndex,int PageSize,string sqlString)
{
try
{
PetaPoco.Page<T> target;
using (PetaPoco.Database db = new PetaPoco.Database(DbConfig.ConnectionString))
{
target = db.Page<T>(pageIndex, PageSize, sqlString);
} return target;
}
catch (Exception ep)
{
// 系统错误日志 级别： 严重错
return null;
}
}
public PetaPoco.Page<T> GetPageData(int pageIndex, int PageSize, string sqlString,object[] obj)
{
try
{
PetaPoco.Page<T> target;
using (PetaPoco.Database db = new PetaPoco.Database(DbConfig.ConnectionString))
{
target = db.Page<T>(pageIndex, PageSize, sqlString,obj);
}
return target;
}
catch (Exception ep)
{
// 系统错误日志 级别： 严重错误
return null;
}
}
PetaPoco 插入数据
public bool Insert(T t)
{
try
{
object obj=null;
using (PetaPoco.Database db = new PetaPoco.Database(DbConfig.ConnectionString))
{
obj= db.Insert(t);
}
return (obj !=null) ? true:false;
}
catch (Exception ep)
{
// 系统错误日志 级别： 严重错误
return false;
}
}
PetaPoco 删除操作
public bool Delete(T t)
{
try
{
int i=0; using (PetaPoco.Database db = new PetaPoco.Database(DbConfig.ConnectionString))
{
i= db.Delete(t);
}
return (i>0)?true:false;
}
catch (Exception ep)
{
// 系统错误日志 级别： 严重错误
return false;
}
}
PetaPoco 更新操作
public bool Update(T t)
{
try
{
int i =0; using (PetaPoco.Database db = new PetaPoco.Database(DbConfig.ConnectionString))
{
i= db.Update(t);
}
return (i>0) ? true: false;
}
catch (Exception ep)
{
// 系统错误日志 级别： 严重错误
return false;
}
}
PetaPoco 中使用事务
public bool Insert(List<T> ts)
{
try
{
object obj=null;
using (PetaPoco.Database db = new PetaPoco.Database(DbConfig.ConnectionString))
{
db.BeginTransaction(); // 使用事务
if(ts !=null && ts.Count>0)
{
foreach (var t in ts)
{
obj= db.Insert(t);
}
db.CompleteTransaction(); // 提交事务
return true;
}
}
return false;
}
catch (Exception ep)
{
// 系统错误日志 级别： 严重错误
return false;
}
}