📄 dbgrxx.cs
字号:
using System;
using CallCenter.IDAL;
using CallCenter.Modules;
using System.Data;
using System.Data.SqlClient;
using System.Data.OracleClient;
using System.Collections;
using System.Text;
using System.IO;
namespace CallCenter.OracleDAL
{
/// <summary>
///
/// </summary>
public class DBGrxx:IGrxx
{
public DBGrxx()
{
//
// TODO: 在此处添加构造函数逻辑
//
}
#region IGrxx 成员
public int getSFZHCount(string sfzh)
{
GrxxInfo info = new GrxxInfo();
string selSql = "SELECT count(*) From grxx WHERE sfzh=@sfzh";
SqlParameter[] param = new SqlParameter[]
{
new SqlParameter("@sfzh",SqlDbType.VarChar,50),
};
param[0].Value = sfzh;
try
{
int i = Convert.ToInt32(OraHelper.SqlserverExecuteScalar(OraHelper.GetSqlserverConnection(),CommandType.Text,selSql,param));
return i;
}
catch(Exception e)
{
throw e;
}
}
public int addGrxx(GrxxInfo info)
{
if( info == null)
throw new Exception("The Sysoperator Object is null,Can't Save Null object!");
//判断身份证号是否重复
if(getSFZHCount(info.sfzh)>0)
{
return -1;
}
string addSql = "INSERT INTO grxx(khxm, sfzh, khly, xb, nl, khsd, whcd, sf, cs, yzbm, xxdz, qh, yddh, cz, dzyx, yyah,zy, zw, ysr, tsjnrq, tsjnnr, bz) VALUES(@khxm, @sfzh, @khly, @xb, @nl, @khsd, @whcd, @sf, @cs, @yzbm, @xxdz, @qh, @yddh, @cz, @dzyx, @yyah,@zy, @zw, @ysr, @tsjnrq, @tsjnnr, @bz)";
SqlParameter[] param = new SqlParameter[]
{
new SqlParameter("@khxm",SqlDbType.VarChar,50),
new SqlParameter("@sfzh",SqlDbType.VarChar,50),
new SqlParameter("@khly",SqlDbType.VarChar,200),
new SqlParameter("@xb",SqlDbType.VarChar,50),
new SqlParameter("@nl",SqlDbType.Int,4),
new SqlParameter("@khsd",SqlDbType.VarChar,200),
new SqlParameter("@whcd",SqlDbType.VarChar,50),
new SqlParameter("@sf",SqlDbType.VarChar,50),
new SqlParameter("@cs",SqlDbType.VarChar,50),
new SqlParameter("@yzbm",SqlDbType.VarChar,50),
new SqlParameter("@xxdz",SqlDbType.VarChar,200),
new SqlParameter("@qh",SqlDbType.VarChar,50),
new SqlParameter("@yddh",SqlDbType.VarChar,50),
new SqlParameter("@cz",SqlDbType.VarChar,50),
new SqlParameter("@dzyx",SqlDbType.VarChar,50),
new SqlParameter("@yyah",SqlDbType.VarChar,50),
new SqlParameter("@zy",SqlDbType.VarChar,50),
new SqlParameter("@zw",SqlDbType.VarChar,50),
new SqlParameter("@ysr",SqlDbType.Decimal,9),
new SqlParameter("@tsjnrq",SqlDbType.DateTime,8),
new SqlParameter("@tsjnnr",SqlDbType.VarChar,200),
new SqlParameter("@bz",SqlDbType.VarChar,2000),
};
param[0].Value = info.khxm;
param[1].Value = info.sfzh;
param[2].Value = info.khly;
param[3].Value = info.xb;
param[4].Value = info.nl;
param[5].Value = info.khsd;
param[6].Value = info.whcd;
param[7].Value = info.sf;
param[8].Value = info.cs;
param[9].Value = info.yzbm;
param[10].Value = info.xxdz;
param[11].Value = info.qh;
param[12].Value = info.yddh;
param[13].Value = info.cz;
param[14].Value = info.dzyx;
param[15].Value = info.yyah;
param[16].Value = info.zy;
param[17].Value = info.zw;
param[18].Value = info.ysr;
param[19].Value = info.tsjnrq;
param[20].Value = info.tsjnnr;
param[21].Value = info.bz;
try
{
OraHelper.SqlserverExecuteNonQuery(OraHelper.GetSqlserverConnection(),CommandType.Text,addSql,param);
}
catch(Exception e)
{
throw e;
}
finally
{
;
}
return 1;
}
public int updateGrxx(GrxxInfo info)
{
if( info == null)
throw new Exception("The Sysoperator Object is null,Can't Save Null object!");
//判断身份证号是否重复
// if(info.sfzh.Equals(this.getGrxxByid(info.id).sfzh))
// {
// return -1;
// }
string updateSql = "UPDATE Grxx SET khxm=@khxm, sfzh=@sfzh, khly=@khly, xb=@xb, nl=@nl, khsd=@khsd, whcd=@whcd, sf=@sf, cs=@cs, yzbm=@yzbm, xxdz=@xxdz, qh=@qh, dh=@dh,yddh=@yddh, cz=@cz, dzyx=@dzyx, yyah=@yyah,zy=@zy, zw=@zw, ysr=@ysr, tsjnrq=@tsjnrq, tsjnnr=@tsjnnr, bz=@bz WHERE id=@id";
SqlParameter[] param = new SqlParameter[]
{
new SqlParameter("@id",SqlDbType.Int,4),
new SqlParameter("@khxm",SqlDbType.VarChar,50),
new SqlParameter("@sfzh",SqlDbType.VarChar,50),
new SqlParameter("@khly",SqlDbType.VarChar,200),
new SqlParameter("@xb",SqlDbType.VarChar,50),
new SqlParameter("@nl",SqlDbType.Int,4),
new SqlParameter("@khsd",SqlDbType.VarChar,200),
new SqlParameter("@whcd",SqlDbType.VarChar,50),
new SqlParameter("@sf",SqlDbType.VarChar,50),
new SqlParameter("@cs",SqlDbType.VarChar,50),
new SqlParameter("@yzbm",SqlDbType.VarChar,50),
new SqlParameter("@xxdz",SqlDbType.VarChar,200),
new SqlParameter("@qh",SqlDbType.VarChar,50),
new SqlParameter("@dh",SqlDbType.VarChar,50),
new SqlParameter("@yddh",SqlDbType.VarChar,50),
new SqlParameter("@cz",SqlDbType.VarChar,50),
new SqlParameter("@dzyx",SqlDbType.VarChar,50),
new SqlParameter("@yyah",SqlDbType.VarChar,50),
new SqlParameter("@zy",SqlDbType.VarChar,50),
new SqlParameter("@zw",SqlDbType.VarChar,50),
new SqlParameter("@ysr",SqlDbType.Decimal,9),
new SqlParameter("@tsjnrq",SqlDbType.DateTime,8),
new SqlParameter("@tsjnnr",SqlDbType.VarChar,200),
new SqlParameter("@bz",SqlDbType.VarChar,2000),
};
param[0].Value = info.id;
param[1].Value = info.khxm;
param[2].Value = info.sfzh;
param[3].Value = info.khly;
param[4].Value = info.xb;
param[5].Value = info.nl;
param[6].Value = info.khsd;
param[7].Value = info.whcd;
param[8].Value = info.sf;
param[9].Value = info.cs;
param[10].Value = info.yzbm;
param[11].Value = info.xxdz;
param[12].Value = info.qh;
param[13].Value = info.dh;
param[14].Value = info.yddh;
param[15].Value = info.cz;
param[16].Value = info.dzyx;
param[17].Value = info.yyah;
param[18].Value = info.zy;
param[19].Value = info.zw;
param[20].Value = info.ysr;
param[21].Value = info.tsjnrq;
param[22].Value = info.tsjnnr;
param[23].Value = info.bz;
try
{
return OraHelper.SqlserverExecuteNonQuery(OraHelper.GetSqlserverConnection(),CommandType.Text,updateSql,param);
}
catch(Exception e)
{
throw e;
}
finally
{
;
}
}
public int delGrxx(string ids)
{
string delSql = "DELETE FROM grxx WHERE id IN('"+ids.Replace("'","''").Replace(",","','")+"')";
try
{
int val=OraHelper.SqlserverExecuteNonQuery(OraHelper.GetSqlserverConnection(),CommandType.Text,delSql,null);
return val;
}
catch(Exception e)
{
throw e;
}
finally
{
;
}
}
public GrxxInfo getGrxxByid(int id)
{
GrxxInfo info = new GrxxInfo();
string selSql = "SELECT khxm, sfzh, khly, xb, nl, khsd, whcd, sf, cs, yzbm, xxdz, qh,dh ,yddh, cz, dzyx, yyah,zy, zw, ysr, tsjnrq, tsjnnr, bz FROM grxx WHERE id=@id";
SqlParameter[] param = new SqlParameter[]
{
new SqlParameter("@id",SqlDbType.Int,4),
};
param[0].Value = id;
try
{
SqlDataReader dr = OraHelper.SqlserverExecuteReader(OraHelper.GetSqlserverConnection(),CommandType.Text,selSql,param);
if(dr.Read())
{
// info.id= dr.IsDBNull(0)?0:dr.GetInt32(0);
info.khxm = dr.IsDBNull(0)?"":dr.GetString(0);
info.sfzh = dr.IsDBNull(1)?"":dr.GetString(1);
info.khly = dr.IsDBNull(2)?"":dr.GetString(2);
info.xb = dr.IsDBNull(3)?"":dr.GetString(3);
info.nl = dr.IsDBNull(4)?0:dr.GetInt32(4);
info.khsd = dr.IsDBNull(5)?"":dr.GetString(5);
info.whcd = dr.IsDBNull(6)?"":dr.GetString(6);
info.sf = dr.IsDBNull(7)?"":dr.GetString(7);
info.cs = dr.IsDBNull(8)?"":dr.GetString(8);
info.yzbm = dr.IsDBNull(9)?"":dr.GetString(9);
info.xxdz = dr.IsDBNull(10)?"":dr.GetString(10);
info.qh = dr.IsDBNull(11)?"":dr.GetString(11);
info.dh = dr.IsDBNull(12)?"":dr.GetString(12);
info.yddh = dr.IsDBNull(13)?"":dr.GetString(13);
info.cz = dr.IsDBNull(14)?"":dr.GetString(14);
info.dzyx = dr.IsDBNull(15)?"":dr.GetString(15);
info.yyah = dr.IsDBNull(16)?"":dr.GetString(16);
info.zy = dr.IsDBNull(17)?"":dr.GetString(17);
info.zw = dr.IsDBNull(18)?"":dr.GetString(18);
info.ysr = dr.IsDBNull(19)?0:dr.GetDecimal(19);
info.tsjnrq = dr.IsDBNull(20)?DateTime.Today:dr.GetDateTime(20);
info.tsjnnr = dr.IsDBNull(21)?"":dr.GetString(21);
info.bz = dr.IsDBNull(22)?"":dr.GetString(22);
}
dr.Close();
}
catch(Exception e)
{
throw e;
}
return info;
}
public DataSet getALLGrxx_DataSet(string tableName)
{
string selSql = "SELECT id,khxm, sfzh, khly, xb, nl, khsd, whcd, sf, cs, yzbm, xxdz, qh,dh, yddh, cz, dzyx, yyah,zy, zw, ysr, tsjnrq, tsjnnr, bz FROM grxx";
try
{
//return OraHelper.ExecuteDataSet(OraHelper.GetOracleConnection(),CommandType.Text,tableName,selSql,null);
return OraHelper.SqlserverExecuteDataSet(OraHelper.GetSqlserverConnection(),CommandType.Text,tableName,selSql,null);
}
catch(Exception e)
{
throw e;
}
}
// public DataSet getDic_DataSet(string tableName,string id,string name)
// {
// string selSql = "SELECT "+id+","+name+" FROM "+tableName;
//
// try
// {
// return OraHelper.SqlserverExecuteDataSet(OraHelper.GetSqlserverConnection(),CommandType.Text,tableName,selSql,null);
// }
// catch(Exception e)
// {
// throw e;
// }
// }
#endregion
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -