using System; using System.Data; using System.Text; using System.Data.SqlClient; using Maticsoft.DBUtility;//Please add references namespace Maticsoft.DAL { /// /// 数据访问类:nr_z_cprk /// public partial class nr_z_cprk { public nr_z_cprk() { } #region BasicMethod /// /// 得到最大ID /// public int GetMaxId() { return DbHelperSQL.GetMaxID("id", "nr_z_cprk"); } /// /// 是否存在该记录 /// public bool Exists(int id) { StringBuilder strSql = new StringBuilder(); strSql.Append("select count(1) from nr_z_cprk"); strSql.Append(" where id=@id"); SqlParameter[] parameters = { new SqlParameter("@id", SqlDbType.Int,4) }; parameters[0].Value = id; return DbHelperSQL.Exists(strSql.ToString(), parameters); } /// /// 增加一条数据 /// public int Add(Maticsoft.Model.nr_z_cprk model) { StringBuilder strSql = new StringBuilder(); strSql.Append("insert into nr_z_cprk("); strSql.Append("rkbh,riqi,scdh,kw,cpbh,cpmc,rkxm,bzgg,guige,zzsl,lt,sl,danwei,songhuoren,shdizhi,zje,jsr,beizhu,zt)"); strSql.Append(" values ("); strSql.Append("@rkbh,@riqi,@scdh,@kw,@cpbh,@cpmc,@rkxm,@bzgg,@guige,@zzsl,@lt,@sl,@danwei,@songhuoren,@shdizhi,@zje,@jsr,@beizhu,@zt)"); strSql.Append(";select @@IDENTITY"); SqlParameter[] parameters = { new SqlParameter("@rkbh", SqlDbType.VarChar,50), new SqlParameter("@riqi", SqlDbType.DateTime), new SqlParameter("@scdh", SqlDbType.VarChar,50), new SqlParameter("@kw", SqlDbType.VarChar,2000), new SqlParameter("@cpbh", SqlDbType.VarChar,50), new SqlParameter("@cpmc", SqlDbType.VarChar,50), new SqlParameter("@rkxm", SqlDbType.VarChar,50), new SqlParameter("@bzgg", SqlDbType.Decimal,9), new SqlParameter("@guige", SqlDbType.Decimal,9), new SqlParameter("@zzsl", SqlDbType.Int,4), new SqlParameter("@lt", SqlDbType.Decimal,9), new SqlParameter("@sl", SqlDbType.Decimal,9), new SqlParameter("@danwei", SqlDbType.VarChar,50), new SqlParameter("@zje", SqlDbType.Decimal,9), new SqlParameter("@jsr", SqlDbType.VarChar,50), new SqlParameter("@beizhu", SqlDbType.VarChar,2000), new SqlParameter("@zt", SqlDbType.VarChar,50)}; parameters[0].Value = model.rkbh; parameters[1].Value = model.riqi; parameters[2].Value = model.scdh; parameters[3].Value = model.kw; parameters[4].Value = model.cpbh; parameters[5].Value = model.cpmc; parameters[6].Value = model.rkxm; parameters[7].Value = model.bzgg; parameters[8].Value = model.guige; parameters[9].Value = model.zzsl; parameters[10].Value = model.lt; parameters[11].Value = model.sl; parameters[12].Value = model.danwei; parameters[13].Value = model.zje; parameters[14].Value = model.jsr; parameters[15].Value = model.beizhu; parameters[16].Value = model.zt; object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters); if (obj == null) { return 0; } else { return Convert.ToInt32(obj); } } /// /// 更新一条数据 /// public bool Update(Maticsoft.Model.nr_z_cprk model) { /* rkbh riqi scdh kw cpbh cpmc rkxm bzgg guige zzsl lt sl danwei zje jsr beizhu zt */ StringBuilder strSql = new StringBuilder(); strSql.Append("update nr_z_cprk set "); strSql.Append("rkbh=@rkbh,"); strSql.Append("riqi=@riqi,"); strSql.Append("scdh=@scdh,"); strSql.Append("kw=@kw,"); strSql.Append("cpbh=@cpbh,"); strSql.Append("cpmc=@cpmc,"); strSql.Append("rkxm=@rkxm,"); strSql.Append("bzgg=@bzgg,"); strSql.Append("guige=@guige,"); strSql.Append("zzsl=@zzsl,"); strSql.Append("lt=@lt,"); strSql.Append("sl=@sl,"); strSql.Append("danwei=@danwei,"); strSql.Append("zje=@zje,"); strSql.Append("jsr=@jsr,"); strSql.Append("beizhu=@beizhu,"); strSql.Append("zt=@zt"); strSql.Append(" where id=@id"); SqlParameter[] parameters = { new SqlParameter("@rkbh", SqlDbType.VarChar,50), new SqlParameter("@riqi", SqlDbType.DateTime), new SqlParameter("@scdh", SqlDbType.VarChar,50), new SqlParameter("@kw", SqlDbType.VarChar,2000), new SqlParameter("@cpbh", SqlDbType.VarChar,50), new SqlParameter("@cpmc", SqlDbType.VarChar,50), new SqlParameter("@rkxm", SqlDbType.VarChar,50), new SqlParameter("@bzgg", SqlDbType.Decimal,9), new SqlParameter("@guige", SqlDbType.Decimal,9), new SqlParameter("@zzsl", SqlDbType.Int,4), new SqlParameter("@lt", SqlDbType.Decimal,9), new SqlParameter("@sl", SqlDbType.Decimal,9), new SqlParameter("@danwei", SqlDbType.VarChar,50), new SqlParameter("@zje", SqlDbType.Decimal,9), new SqlParameter("@jsr", SqlDbType.VarChar,50), new SqlParameter("@beizhu", SqlDbType.VarChar,2000), new SqlParameter("@zt", SqlDbType.VarChar,50), new SqlParameter("@id", SqlDbType.Int,4)}; parameters[0].Value = model.rkbh; parameters[1].Value = model.riqi; parameters[2].Value = model.scdh; parameters[3].Value = model.kw; parameters[4].Value = model.cpbh; parameters[5].Value = model.cpmc; parameters[6].Value = model.rkxm; parameters[7].Value = model.bzgg; parameters[8].Value = model.guige; parameters[9].Value = model.zzsl; parameters[10].Value = model.lt; parameters[11].Value = model.sl; parameters[12].Value = model.danwei; parameters[13].Value = model.zje; parameters[14].Value = model.jsr; parameters[15].Value = model.beizhu; parameters[16].Value = model.zt; parameters[17].Value = model.id; int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 删除一条数据 /// public bool Delete(int id) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from nr_z_cprk "); strSql.Append(" where id=@id"); SqlParameter[] parameters = { new SqlParameter("@id", SqlDbType.Int,4) }; parameters[0].Value = id; int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 批量删除数据 /// public bool DeleteList(string idlist) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from nr_z_cprk "); strSql.Append(" where id in (" + idlist + ") "); int rows = DbHelperSQL.ExecuteSql(strSql.ToString()); if (rows > 0) { return true; } else { return false; } } /// /// 得到一个对象实体 /// public Maticsoft.Model.nr_z_cprk GetModel(int id) { StringBuilder strSql = new StringBuilder(); strSql.Append("select top 1 id,rkbh, riqi, scdh, kw, cpbh, cpmc, rkxm, bzgg, guige, zzsl, lt, sl, danwei, zje, jsr, beizhu, zt from nr_z_cprk "); strSql.Append(" where id=@id"); SqlParameter[] parameters = { new SqlParameter("@id", SqlDbType.Int,4) }; parameters[0].Value = id; Maticsoft.Model.nr_z_cprk model = new Maticsoft.Model.nr_z_cprk(); DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters); if (ds.Tables[0].Rows.Count > 0) { return DataRowToModel(ds.Tables[0].Rows[0]); } else { return null; } } /// /// 得到一个对象实体 /// public Maticsoft.Model.nr_z_cprk DataRowToModel(DataRow row) { var model = Mapper.CreateItem(row); return model; } /// /// 获得数据列表 /// public DataSet GetList(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select id,rkbh, riqi, scdh, kw, cpbh, cpmc, rkxm, bzgg, guige, zzsl, lt, sl, danwei, zje, jsr, beizhu, zt "); strSql.Append(" FROM nr_z_cprk "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } return DbHelperSQL.Query(strSql.ToString()); } /// /// 获得前几行数据 /// public DataSet GetList(int Top, string strWhere, string filedOrder) { StringBuilder strSql = new StringBuilder(); strSql.Append("select "); if (Top > 0) { strSql.Append(" top " + Top.ToString()); } strSql.Append(" id,rkbh, riqi, scdh, kw, cpbh, cpmc, rkxm, bzgg, guige, zzsl, lt, sl, danwei, zje, jsr, beizhu, zt "); strSql.Append(" FROM nr_z_cprk "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } strSql.Append(" order by " + filedOrder); return DbHelperSQL.Query(strSql.ToString()); } /// /// 获取记录总数 /// public int GetRecordCount(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select count(1) FROM nr_z_cprk "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } object obj = DbHelperSQL.GetSingle(strSql.ToString()); if (obj == null) { return 0; } else { return Convert.ToInt32(obj); } } /// /// 分页获取数据列表 /// public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex) { StringBuilder strSql = new StringBuilder(); strSql.Append("SELECT * FROM ( "); strSql.Append(" SELECT ROW_NUMBER() OVER ("); if (!string.IsNullOrEmpty(orderby.Trim())) { strSql.Append("order by T." + orderby); } else { strSql.Append("order by T.id desc"); } strSql.Append(")AS Row, T.* from nr_z_cprk T "); if (!string.IsNullOrEmpty(strWhere.Trim())) { strSql.Append(" WHERE " + strWhere); } strSql.Append(" ) TT"); strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex); return DbHelperSQL.Query(strSql.ToString()); } /* /// /// 分页获取数据列表 /// public DataSet GetList(int PageSize,int PageIndex,string strWhere) { SqlParameter[] parameters = { new SqlParameter("@tblName", SqlDbType.VarChar, 255), new SqlParameter("@fldName", SqlDbType.VarChar, 255), new SqlParameter("@PageSize", SqlDbType.Int), new SqlParameter("@PageIndex", SqlDbType.Int), new SqlParameter("@IsReCount", SqlDbType.Bit), new SqlParameter("@OrderType", SqlDbType.Bit), new SqlParameter("@strWhere", SqlDbType.VarChar,1000), }; parameters[0].Value = "nr_z_cprk"; parameters[1].Value = "id"; parameters[2].Value = PageSize; parameters[3].Value = PageIndex; parameters[4].Value = 0; parameters[5].Value = 0; parameters[6].Value = strWhere; return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds"); }*/ #endregion BasicMethod #region ExtensionMethod #endregion ExtensionMethod } }