【Java开源代码栏目提醒】:网学会员--在 Java开源代码编辑为广大网友搜集整理了:WareKindDao.java绩等信息,祝愿广大网友取得需要的信息,参考学习。
package com.dao;
import com.tool.JDBConnection;
import java.util.*;
import com.domain.WareKindVO;
import java.sql.*;
public class WareKindDao {
private JDBConnection connection = null;
public WareKindDao() {
connection = new JDBConnection();
this.connection.creatConnection(); //利用构造方法调用类中的对象对数据库创建连接
}
//查询全部的计量单位
public List kindSelect() {
List list = new ArrayList();
WareKindVO kind = null;
String sql = "select * from tb_kind order by id";
ResultSet rs = connection.executeQuery(sql);
try {
while (rs.next()) {
kind = new WareKindVO();
kind.setId(Integer.valueOf(rs.getString(1)));
kind.setKind_number(rs.getString(2));
kind.setKind_name(rs.getString(3));
kind.setKind_remark(rs.getString(4));
list.add(kind);
}
}
catch (SQLException ex) {
}
connection.closeConnection();
return list;
}
//以员工编号为条件
查询信息
public WareKindVO kindSelectOne(String number) {
WareKindVO kind = null;
String sql = "select * from tb_kind where kind_number='" + number + "'";
ResultSet rs = connection.executeQuery(sql);
try {
while (rs.next()) {
kind = new WareKindVO();
kind.setId(Integer.valueOf(rs.getString(1)));
kind.setKind_number(rs.getString(2));
kind.setKind_name(rs.getString(3));
kind.setKind_remark(rs.getString(4));
}
}
catch (SQLException ex) {
}
connection.closeConnection();
return kind;
}
//以名称为条件查询
public WareKindVO kindSelectName(String name) {
WareKindVO kind = null;
String sql = "select * from tb_kind where kind_name='" + name + "'";
ResultSet rs = connection.executeQuery(sql);
try {
while (rs.next()) {
kind = new WareKindVO();
kind.setId(Integer.valueOf(rs.getString(1)));
kind.setKind_number(rs.getString(2));
kind.setKind_name(rs.getString(3));
kind.setKind_remark(rs.getString(4));
}
}
catch (SQLException ex) {
}
connection.closeConnection();
return kind;
}
//添加操作
public void kindInsert(WareKindVO vo) {
String
sql = "insert into tb_kind values ('" + vo.getKind_number() + "','" +
vo.getKind_name() + "','" + vo.getKind_remark() + "')";
connection.executeUpdate(sql);
connection.closeConnection();
}
//删除操作
public void kindDelete(Integer id) {
String sql = "delete from tb_kind where id='" + id + "'";
connection.executeUpdate(sql);
connection.closeConnection();
}
//修改编号的操作
public void kindUpdateNumber(Integer id, String number) {
String unNumber = "kind-" + String.valueOf(id);
String sql = "update tb_kind set kind_number='" + unNumber +
"' where kind_number='" + number + "'";
connection.executeUpdate(sql);
connection.closeConnection();
}
//修改操作
public void kindUpdate(WareKindVO vo) {
String sql = "update tb_kind set kind_name='" + vo.getKind_name() +
"',kind_remark='" + vo.getKind_remark() + "' where kind_number='" +
vo.getKind_number() + "'";
connection.executeUpdate(sql);
connection.closeConnection();
}
}