c#，java数据库操作
c#:
public class xunwudaoimp :xunwuDao
{
public int add(Xun xunwu)
{
DBHelper dbHelper = new DBHelper();
//用参数方式，构造sql语句
string sql = "insert into xunwu values(@id,@pass,@sname,@date,@adress, @goods)";
//构造参数数组,对参数变量进行赋值
SqlParameter[] param = {
new SqlParameter("@id",xunwu.Id),
new SqlParameter("@pass",xunwu.Pass),
new SqlParameter("@sname",xunwu.Sname),
new SqlParameter("@date",xunwu.Date),
new SqlParameter("@adress",xunwu.Adress),
new SqlParameter("@goods",xunwu.Goods)
};
int count = dbHelper.excute(sql, param);
return count;
}
public Xun login(int id, string pwd)
{
DBHelper dbHelper = new DBHelper();
//3.建立指令
string sql = "select * from xunwu where id=@id and pass=@password";
SqlParameter[] para = {
new SqlParameter("@id",id),
new SqlParameter("@password",pwd)
};
DataSet ds = dbHelper.query(sql, para);
//判断查询是否为空，不为空，返回第一条数据
if (ds != null && ds.Tables[0].Rows.Count > 0)
{
Xun xunwu = new Xun();
//获取第一条数据，并封装到model
xunwu.Id = int.Parse(ds.Tables[0].Rows[0]["id"].ToString());
xunwu .Pass = ds.Tables[0].Rows[0]["pass"].ToString();
xunwu.Sname = ds.Tables[0].Rows[0]["sname"].ToString();
return xunwu ;
}
else
{
return null;
}
}
public int del(int keyid)
{
DBHelper dbHelper = new DBHelper();
//用参数方式，构造sql语句
string sql = "delete from xunwu where id=@keyid";
//构造参数数组,对参数变量进行赋值
SqlParameter[] param = {
new SqlParameter("@keyid",keyid)
};
int count = dbHelper.excute(sql, param);
return count;
}
public int update(Xun xunwu)
{
DBHelper dbHelper = new DBHelper();
//用参数方式，构造sql语句
string sql = "update xunwu set pass=@pass,sname=@sname,adress=@adress,goods=@goods,date=@date where id=@id";
//构造参数数组,对参数变量进行赋值
SqlParameter[] param = {
new SqlParameter("@id",xunwu.Id),
new SqlParameter("@pass",xunwu.Pass),
new SqlParameter("@sname",xunwu.Sname),
new SqlParameter("@date",xunwu.Date),
new SqlParameter("@adress",xunwu.Adress),
new SqlParameter("@goods",xunwu.Goods)
};
int count = dbHelper.excute(sql, param);
return count;
}
/* public Xun queryById(int id)
{
DBHelper dbHelper = new DBHelper();
//3.建立指令
string sql = "select * from users where keyid=@keyid";
SqlParameter[] para = {
new SqlParameter("@keyid",id)
};
DataSet ds = dbHelper.query(sql, para);
//判断查询是否为空，不为空，返回第一条数据
if (ds != null && ds.Tables[0].Rows.Count > 0)
{
Users user = new Users();
//获取第一条数据，并封装到model
user.UserName = ds.Tables[0].Rows[0]["username"].ToString();
user.Password = ds.Tables[0].Rows[0]["password"].ToString();
user.Keyid = int.Parse(ds.Tables[0].Rows[0]["keyid"].ToString());
return user;
}
else
{
return null;
}*/
public DataSet query()
{
DBHelper dbHelper = new DBHelper();
//3.建立指令
string sql = "select * from xunwu ";
DataSet ds = dbHelper.query(sql, null);
return ds;
}
public DataSet query1(int id)
{
DBHelper dbHelper = new DBHelper();
//3.建立指令
string sql = "select * from xunwu where id=@id";
SqlParameter[] para = {
new SqlParameter("@id",id)
};
DataSet ds = dbHelper.query(sql,para);
return ds;
}
}
public class DBHelper
{
SqlConnection conn;
//在使用该类时，自动进行链接字符串的初始化，构造函数或者块语句
public DBHelper() {
string strConn = System.Configuration.ConfigurationManager.ConnectionStrings["xunwuConnectionString"].ConnectionString;
//初始化连接对象
conn = new SqlConnection(strConn);
}
public int excute(string sql,SqlParameter[] paras) {//增删改
//建立命令对象
SqlCommand comm = new SqlCommand(sql,conn);
comm.Parameters.AddRange(paras);//加入参数
//打开链接
conn.Open();
int count= comm.ExecuteNonQuery();
//关闭连接
conn.Close();
return count;
}
public DataSet query(string sql, SqlParameter[] paras) {
//建立数据集对象
DataSet ds = new DataSet();
//建立数据适配器
SqlDataAdapter adpter = new SqlDataAdapter(sql,conn);
if(paras!=null)
adpter.SelectCommand.Parameters.AddRange(paras);
conn.Open();
//填充数据
adpter.Fill(ds);
conn.Close();
return ds;
}
}
java:
public class XunDaoimple implements XunwuDao{
@Resource(name="jdbcTemplate")
JdbcTemplate jdbcTemplate;
@Override
public int add(Xunwu xun) {
String sql="insert into xunwu(id,pass,sname,date,adress,goods) values(?,?,?,?,?,?)";
Object[] obj=new Object[]{xun.getId(),xun.getPass(),xun.getSname(),xun.getDate(),xun.getAdress(),xun.getGoods()};
int num= jdbcTemplate.update(sql,obj);
return num;
}
@Override
public int update(Xunwu xun) {
String sql="update xunwu set pass=?,sname=?,date=?,adress=?,goods=? where id=?";
Object[] obj=new Object[]{xun.getPass(),xun.getSname(),xun.getDate(),xun.getAdress(),xun.getGoods(),xun.getId()};
int num= jdbcTemplate.update(sql,obj);
return num;
}
@Override
public int delete(int id) {
String sql="delete from xunwu where id=?";
int num= jdbcTemplate.update(sql,id);
return num;
}
@Override
public List<Xunwu> query(int id) {
String sql="select * from xunwu where id=?";
RowMapper<Xunwu> rm=new BeanPropertyRowMapper<Xunwu>( Xunwu.class);
List<Xunwu> st=(List<Xunwu>)jdbcTemplate.query(sql,rm,id);
return st;
}
@Override
public List<Xunwu> login(int id,String pass) {
String sql="select * from xunwu where id=? and pass=? ";
RowMapper<Xunwu> rm=new BeanPropertyRowMapper<Xunwu>(Xunwu.class);
List<Xunwu> st=(List<Xunwu>)jdbcTemplate.query(sql,rm,id,pass);
return st;
}
@Override
public List<Xunwu> queryAll() {
String sql="select * from xunwu ";
RowMapper<Xunwu> rm=new BeanPropertyRowMapper<Xunwu>( Xunwu.class);
Object[] obj=new Object[]{ };
List<Xunwu> slist=(List<Xunwu>)jdbcTemplate.query(sql, rm,obj);
return slist;
}
}
微信扫一扫，打赏作者吧～扫描二维码推送至手机访问。
版权声明：本文由一段神奇的代码发布，如需转载请注明出处。
