1.6 公共模块设计
在本系统的项目空间中，有部分模块（或者是多个模块甚至整个系统的配置信息）是公用的，它们被多个模块重复调用完成指定的业务逻辑，本节将这些公共模块提出来加以单独介绍。
1.6.1 编写Dao公共类
Dao类主要负责有关数据库的操作，该类在静态代码段中驱动并连接数据库，然后将所有的数据库访问方法定义为静态的。本节将介绍Dao类中有关数据库操作的关键方法。Dao类的定义代码如下：
例程09 代码位置：光盘\TM\01\JXCManager\src\com\lzw\dao\Dao.java
public class Dao {
protected static String dbClassName = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
protected static String dbUrl = "jdbc:microsoft:sqlserver://localhost:1433;"
+ "DatabaseName=db_JXC;SelectMethod=Cursor";
protected static String dbUser = "sa";
protected static String dbPwd = "";
protected static String second = null;
public static Connection conn = null;
static {
try {
if (conn == null) {
Class.forName(dbClassName).newInstance(); //加载数据库驱动类
conn = DriverManager.getConnection(dbUrl, dbUser, dbPwd); //获取数据库连接
}
} catch (Exception ee) {
ee.printStackTrace();
}
}
}
代码贴士
dbClassName：该成员变量用于定义数据库驱动类的名称。
dbUrl：该成员变量用于定义访问数据库的URL路径。
dbUser：该成员变量用于定义访问数据库的用户名称。
dbPwd：该成员变量用于定义访问数据库的用户密码。
conn：该成员变量用于定义连接数据库的对象。
1．addGys()方法
该方法用于添加供应商的基础信息，它接收供应商的实体类TbGysinfo作方法的参数，然后把实体对象中的所有属性存入供应商数据表中。关键代码如下：
例程10 代码位置：光盘\TM\01\JXCManager\src\com\lzw\dao\Dao.java
//添加供应商信息的方法
public static boolean addGys(TbGysinfo gysInfo) {
if (gysInfo == null) //如果供应商实体对象为空
return false; //则返回false
return insert("insert tb_gysinfo values('" + gysInfo.getId() + "','" //执行供应商添加
+ gysInfo.getName() + "','" + gysInfo.getJc() + "','"
+ gysInfo.getAddress() + "','" + gysInfo.getBianma() + "','"
+ gysInfo.getTel() + "','" + gysInfo.getFax() + "','"
+ gysInfo.getLian() + "','" + gysInfo.getLtel() + "','"
+ gysInfo.getMail() + "','" + gysInfo.getYh() + "')");
}
2．getGysInfo()方法
该方法将根据Item对象中封装的供应商ID编号和供应商名称获取指定供应商的数据，并将该供应商的数据封装到实体对象中，然后返回该实体对象。关键代码如下：
例程11 代码位置：光盘\TM\01\JXCManager\src\com\lzw\dao\Dao.java
//读取指定供应商信息
public static TbGysinfo getGysInfo(Item item) {
String where = "name='" + item.getName() + "' "; //默认的查询条件以供应商名称为主
if (item.getId() != null) //如果Item对象中存有ID编号
where = "id='" + item.getId() + "' "; //则以ID编号为查询条件
TbGysinfo info = new TbGysinfo();
ResultSet set = findForResultSet("select * from tb_gysinfo where "+ where);
try {
if (set.next()) {
info.setId(set.getString("id").trim()); //封装供应商数据到实体对象中
info.setAddress(set.getString("address").trim());
info.setBianma(set.getString("bianma").trim());
info.setFax(set.getString("fax").trim());
info.setJc(set.getString("jc").trim());
info.setLian(set.getString("lian").trim());
info.setLtel(set.getString("ltel").trim());
info.setMail(set.getString("mail").trim());
info.setName(set.getString("name").trim());
info.setTel(set.getString("tel").trim());
info.setYh(set.getString("yh").trim());
}
} catch (SQLException e) {
e.printStackTrace();
}
return info; //返回供应商实体对象
}
3．updateGys()方法
该方法用于更新供应商的基础信息，它接收供应商的实体类TbGysinfo作方法参数，在方法中直接解析供应商实体对象中的属性，并将这些属性更新到数据表中。关键代码如下：
例程12 代码位置：光盘\TM\01\JXCManager\src\com\lzw\dao\Dao.java
//修改供应商信息的方法
public static int updateGys(TbGysinfo gysInfo) {
return update("update tb_gysinfo set jc='" + gysInfo.getJc()
+ "',address='" + gysInfo.getAddress() + "',bianma='"
+ gysInfo.getBianma() + "',tel='" + gysInfo.getTel()
+ "',fax='" + gysInfo.getFax() + "',lian='" + gysInfo.getLian()
+ "',ltel='" + gysInfo.getLtel() + "',mail='"
+ gysInfo.getMail() + "',yh='" + gysInfo.getYh()
+ "' where id='" + gysInfo.getId() + "'");
}
4．insertRukuInfo()方法
该方法负责完成入库单信息的添加，涉及到库存表、入库主表和入库详细表等多个数据表的操作。为保证数据的完整性，该方法将入库信息的添加操作放在事务中完成，方法将接收入库主表的实体类TbRukuMain作参数，该实体类中包含了入库详细表的引用。关键代码如下：
例程13 代码位置：光盘\TM\01\JXCManager\src\com\lzw\dao\Dao.java
public static boolean insertRukuInfo(TbRukuMain ruMain) { //在事务中添加入库信息
try {
boolean autoCommit = conn.getAutoCommit();
conn.setAutoCommit(false); //取消自动提交模式
insert("insert into tb_ruku_main values('" + ruMain.getRkId() //添加入库主表记录
+ "','" + ruMain.getPzs() + "'," + ruMain.getJe() + ",'"
+ ruMain.getYsjl() + "','" + ruMain.getGysname() + "','"
+ ruMain.getRkdate() + "','" + ruMain.getCzy() + "','"
+ ruMain.getJsr() + "','" + ruMain.getJsfs() + "')");
Set<TbRukuDetail> rkDetails = ruMain.getTabRukuDetails();
for (Iterator<TbRukuDetail> iter = rkDetails.iterator(); iter.hasNext();) {
TbRukuDetail details = iter.next();
insert("insert into tb_ruku_detail values('" + ruMain.getRkId() //添加入库详细表记录
+ "','" + details.getTabSpinfo() + "'," + details.getDj() + "," + details.getSl() + ")");
Item item = new Item();
item.setId(details.getTabSpinfo());
TbSpinfo spInfo = getSpInfo(item);
if (spInfo.getId() != null && !spInfo.getId().isEmpty()) {
TbKucun kucun = getKucun(item);
if (kucun.getId() == null || kucun.getId().isEmpty()) { //添加或修改库存表记录
insert("insert into tb_kucun values('" + spInfo.getId()
+ "','" + spInfo.getSpname() + "','"+ spInfo.getJc() + "','" + spInfo.getCd()
+ "','" + spInfo.getGg() + "','"+ spInfo.getBz() + "','" + spInfo.getDw()
+ "'," + details.getDj() + ","+ details.getSl() + ")");
} else {
int sl = kucun.getKcsl() + details.getSl();
update("update tb_kucun set kcsl=" + sl + ",dj="+ details.getDj() + " where id='"+ kucun.getId() + "'");
}
}
}
conn.commit(); //提交事务
conn.setAutoCommit(autoCommit); //恢复自动提交模式
} catch (SQLException e) {
try {
conn.rollback(); //如果出错，回退事务
} catch (SQLException e1) {
e1.printStackTrace();
}
e.printStackTrace();
}
return true;
}
鄂公网安备 42010302001612号