📄 clientdao.java
字号:
package com.accp.oa.dao.imple;
import java.util.ArrayList;
import com.accp.oa.bean.*;
import com.accp.oa.common.*;
import com.accp.oa.dao.inface.BaseDAO;
import java.sql.*;
/**
* ClientDAO 类
*
* @author zhaogenfei ClientDAO 类主要是客户信息表的操作(增,删,查,改)
*/
public class ClientDAO implements BaseDAO {
public static ClientDAO client = null;
public static ClientDAO getClientDAO() {
if (client == null) {
client = new ClientDAO();
}
return client;
}
/**
* 添加客户(传一个Clientbean的对象,得到它的属性的值,添加到表中) boolean值为是否添加成功true成功,false失败
*/
public boolean add(Object obj) {
boolean success = false;
Clientbean bean = (Clientbean) obj;
Connection con = null;
PreparedStatement stmt = null;
try {
String sql = Constants.ADD_CLIENT;
con = DbUtil.connectToDB();
stmt = con.prepareStatement(sql);
stmt.setString(1, bean.getClientName().trim());
stmt.setString(2, bean.getAddress().trim());
stmt.setString(3, bean.getTelephone().trim());
stmt.setString(4, bean.getFax().trim());
stmt.setString(5, bean.getEmail().trim());
stmt.setString(6, bean.getNet().trim());
stmt.setString(7, bean.getCalling().trim());
stmt.setString(8, bean.getDemand().trim());
stmt.setDouble(9, bean.getMoney());
stmt.setString(10, bean.getPart().trim());
stmt.setString(11, bean.getLinkman().trim());
stmt.setString(12, bean.getSex().trim());
stmt.setString(13, bean.getDuty().trim());
stmt.setString(14, bean.getTel().trim());
stmt.setString(15, bean.getRemark().trim());
int a = stmt.executeUpdate();
if (a > 0) {
success = true;
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (stmt != null)
stmt.close();
if (con != null)
con.close();
} catch (Exception ex) {
ex.printStackTrace();
}
}
return success;
}
/**
* 这个方法用于得到分页的数据
*
* @param num
* 传入的页数
* @param tablename
* 要查询的表明
* @param selectname
* 查询的条件
* @return 集合,查询的结果
*/
public ArrayList search(String num, String tablename, String selectname) {
Statement stmt = null;
ResultSet rs = null;
Connection con = null;
ArrayList list = new ArrayList();
if (num == null || null == "")
num = "1";
int number = Integer.parseInt(num);
String sql = commonDAO.GetcomonDAO().getSQL(number, tablename,
selectname);
try {
con = DbUtil.connectToDB();
} catch (Exception e1) {
e1.printStackTrace();
}
try {
stmt = con.createStatement();
rs = stmt.executeQuery(sql);
Clientbean bean = null;
while (rs.next()) {
bean = new Clientbean();
bean.setId(rs.getInt("Id"));
bean.setClientName(rs.getString("ClientName"));
bean.setAddress(rs.getString("Adress"));
bean.setTelephone(rs.getString("Telephone"));
bean.setFax(rs.getString("Fax"));
bean.setEmail(rs.getString("Eamil"));
bean.setNet(rs.getString("Net"));
bean.setCalling(rs.getString("Calling"));
bean.setDemand(rs.getString("Demand"));
bean.setMoney(rs.getDouble("Money"));
bean.setPart(rs.getString("Explain"));
bean.setLinkman(rs.getString("Linkman"));
bean.setSex(rs.getString("Sex"));
bean.setDuty(rs.getString("Duty"));
bean.setTel(rs.getString("Tel"));
bean.setRemark(rs.getString("Remark"));
list.add(bean);
}
commonDAO.GetcomonDAO().setpagenumber(number);
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if (rs != null)
rs.close();
if (stmt != null) {
stmt.close();
}
if (con != null) {
con.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
return list;
}
public boolean delete(Object obj) {
return false;
}
/**
* 按照id删除记录 boolean 值 true为成功 false失败 id 为客户编号
*/
public boolean delete(int id) {
boolean success = false;
PreparedStatement stmt = null;
Connection con = null;
try {
con = TransDAO.getConnection();
String sql = Constants.DELETE_CLIENT;
stmt = con.prepareStatement(sql);
stmt.setInt(1, id);
int a = stmt.executeUpdate();
if (a > 0)
success = true;
} catch (Exception e) {
e.printStackTrace();
}
return success;
}
public boolean delete(String ag0) {
return false;
}
public Object search(Object obj) {
return null;
}
public Object search(int id) {
return null;
}
/**
* 按照id去搜索 把结果放在集合里面
*/
public ArrayList search(String age0) {
PreparedStatement stmt = null;
Connection con = null;
ResultSet rs = null;
int id = Integer.parseInt(age0);
ArrayList list = new ArrayList();
try {
con = DbUtil.connectToDB();
String sql = Constants.SELECT_CLIENT1;
stmt = con.prepareStatement(sql);
stmt.setInt(1, id);
rs = stmt.executeQuery();
Clientbean bean = null;
while (rs.next()) {
bean = new Clientbean();
bean.setId(rs.getInt("Id"));
bean.setClientName(rs.getString("ClientName"));
bean.setAddress(rs.getString("Adress"));
bean.setTelephone(rs.getString("Telephone"));
bean.setFax(rs.getString("Fax"));
bean.setEmail(rs.getString("Eamil"));
bean.setNet(rs.getString("Net"));
bean.setCalling(rs.getString("Calling"));
bean.setDemand(rs.getString("Demand"));
bean.setMoney(rs.getDouble("Money"));
bean.setPart(rs.getString("Explain"));
bean.setLinkman(rs.getString("Linkman"));
bean.setSex(rs.getString("Sex"));
bean.setDuty(rs.getString("Duty"));
bean.setTel(rs.getString("Tel"));
bean.setRemark(rs.getString("Remark"));
list.add(bean);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (con != null) {
con.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
return list;
}
public ArrayList search(int ag0, int age1) {
return null;
}
public boolean update(Object obj) {
boolean success = false;
Clientbean bean = (Clientbean) obj;
Connection con = null;
PreparedStatement stmt = null;
try {
String sql = Constants.UPDATE_CLIENT;
con = DbUtil.connectToDB();
stmt = con.prepareStatement(sql);
stmt.setString(1, bean.getClientName());
stmt.setString(2, bean.getAddress());
stmt.setString(3, bean.getTelephone());
stmt.setString(4, bean.getFax());
stmt.setString(5, bean.getEmail());
stmt.setString(6, bean.getNet());
stmt.setString(7, bean.getCalling());
stmt.setString(8, bean.getDemand());
stmt.setDouble(9, bean.getMoney());
stmt.setString(10, bean.getPart());
stmt.setString(11, bean.getLinkman());
stmt.setString(12, bean.getSex());
stmt.setString(13, bean.getDuty());
stmt.setString(14, bean.getTel());
stmt.setString(15, bean.getRemark());
stmt.setInt(16, bean.getId());
int a = stmt.executeUpdate();
if (a > 0) {
success = true;
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (stmt != null)
stmt.close();
if (con != null)
con.close();
} catch (Exception ex) {
ex.printStackTrace();
}
}
return success;
}
public ArrayList search() {
// TODO 自动生成方法存根
return null;
}
public int search(String ag0, String ag1) {
// TODO 自动生成方法存根
return 0;
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -