美讯网上购物系统netshop

package com.health.util; import java.io.FileOutputStream; import java.io.OutputStreamWriter; import java.sql.Connection; import java.util.Map; import java.util.Random; import com.health.database.TestDB; /** * DAO模式的公共工具类 * * @author 胡辉煜 */ public class DAOCommon { public static final String ENTITY = ".entity"; public static final String DAO = ".dao"; public static final String DAO_IMPL = ".dao.impl"; public static final String SELECT = "SELECT"; public static final String SELECT_BY_KEY = "SELECT_BY_KEY"; public static final String INSERT = "INSERT"; public static final String DELETE = "DELETE"; public static final String UPDATE = "UPDATE"; public static final String CRLF = String.format("%n"); private DAOCommon() { } /** * 获取指定Table的JavaBean类的java文件字符串 * * @param connection * 数据库连接 * @param tableName * 表名称 * @param packageName * 包名称 * @return 指定Table的JavaBean类的java文件字符串 * @throws Exception */ public static String getTableClassString(Connection connection, String tableName, String packageName) throws Exception { StringBuilder sb = new StringBuilder(); Table table = DBCommon.findTable(connection, tableName); if (table == null) { throw new Exception(String.format("没有找到表：%s", tableName)); } tableName = table.getTableName(); sb.append("package ").append(packageName); sb.append(";").append(CRLF).append(CRLF); // 版权信息 sb.append("/**").append(CRLF); sb.append(" * 胡辉煜数据库Bean自动生成工具").append(CRLF); sb.append(" * 数据库表：").append(tableName).append(CRLF); sb.append(" */").append(CRLF); Map<String, TableColumn> columns = DBCommon.getTableColumns(connection, tableName); // 获取列信息 // 类定义 sb.append("public class ").append(firstToUpper(tableName)); sb.append(" implements java.io.Serializable {").append(CRLF); // 序列化ID Random r = new Random(); long id = r.nextLong(); sb.append("\tprivate static final long serialVersionUID="); sb.append(id).append("L;").append(CRLF); // 字段列表 sb.append(CRLF); for (String name : columns.keySet()) { TableColumn column = columns.get(name); sb.append("\tprivate ").append(column.getClassName()).append(" "); sb.append(firstToLower(name)).append(";").append(CRLF); } // 默认构造函数 sb.append(CRLF); sb.append("\tpublic ").append(firstToUpper(tableName)).append("(){"); sb.append(CRLF).append("\t}").append(CRLF); // getter和setter方法 sb.append(CRLF); for (String name : columns.keySet()) { TableColumn column = columns.get(name); String lName = firstToLower(name); String uName = firstToUpper(name); // getter sb.append("\tpublic ").append(column.getClassName()).append(" "); sb.append("get").append(uName).append(" (){"); sb.append(CRLF); sb.append("\t\treturn ").append(lName).append(";"); sb.append(CRLF).append("\t}").append(CRLF + CRLF); // setter sb.append("\tpublic void set").append(uName).append("("); sb.append(column.getClassName()).append(" "); sb.append(firstToLower(name)).append(") {").append(CRLF); sb.append("\t\tthis.").append(lName); sb.append(" = ").append(lName).append(";"); sb.append(CRLF).append("\t}").append(CRLF + CRLF); } // 复写toString方法 sb.append("\t@Override").append(CRLF); sb.append("\tpublic String toString() {").append(CRLF); sb.append("\t\treturn String.format(\""); for (String name : columns.keySet()) { // // 添加参数格式 sb.append(firstToLower(name)).append(":%s,"); } sb.deleteCharAt(sb.length() - 1);// 删除最后一个,号 sb.append("\""); for (String name : columns.keySet()) { // 添加输出参数 sb.append(",").append(firstToLower(name)); } sb.append(");").append(CRLF); sb.append("\t}").append(CRLF + CRLF); // 类定义结束 sb.append("}"); return sb.toString(); } /** * 获取指定Table的DAO接口类文件字符串 * * @param connection * 数据库连接 * @param tableName * 表名称 * @param packageName * 包名称 * @return 指定Table的DAO接口类文件字符串 * @throws Exception */ public static String getTableDAOString(Connection connection, String tableName, String packageName) throws Exception { StringBuilder sb = new StringBuilder(); Table table = DBCommon.findTable(connection, tableName); if (table == null) { throw new Exception(String.format("没有找到表：%s", tableName)); } tableName = table.getTableName(); // 处理包 sb.append("package ").append(packageName); sb.append(";").append(CRLF).append(CRLF); String beanName = packageName.replace(DAO, ENTITY); beanName += "." + firstToUpper(tableName); sb.append("import ").append(beanName); sb.append(";").append(CRLF).append(CRLF); // 版权信息 sb.append("/**").append(CRLF); sb.append(" * 胡辉煜数据库DAO自动生成工具").append(CRLF); sb.append(" * 数据库表：").append(tableName).append(CRLF); sb.append(" */").append(CRLF); sb.append("public interface ").append(firstToUpper(tableName)); sb.append("DAO {").append(CRLF); // 插入方法 sb.append("\tpublic int insert(").append(firstToUpper(tableName)); sb.append(" ").append(firstToLower(tableName)); sb.append(") throws Exception;").append(CRLF); // 修改方法 sb.append("\tpublic int update(").append(firstToUpper(tableName)); sb.append(" ").append(firstToLower(tableName)); sb.append(") throws Exception;").append(CRLF); // 删除方法 sb.append("\tpublic int delete(").append(firstToUpper(tableName)); sb.append(" ").append(firstToLower(tableName)); sb.append(") throws Exception;").append(CRLF); // 查询全部数据方法 sb.append("\tpublic java.util.List<").append(firstToUpper(tableName)); sb.append("> getAllData() throws Exception;").append(CRLF); // 查询主键数据方法 sb.append("\tpublic ").append(firstToUpper(tableName)); sb.append(" getByKey(").append(firstToUpper(tableName)); sb.append(" ").append(firstToLower(tableName)); sb.append(") throws Exception;").append(CRLF); // 完成 sb.append("}"); return sb.toString(); } /** * 获取指定Table的DAO实现类文件字符串 * * @param connection * 数据库连接 * @param tableName * 表名称 * @param packageName * 包名称 * @return 指定Table的DAO实现类文件字符串 * @throws Exception */ public static String getTableDAOImplString(Connection connection, String tableName, String packageName) throws Exception { Map<String, String> methodMap = DBCommon.getTypeMethodMap(); StringBuilder sb = new StringBuilder(); Table table = DBCommon.findTable(connection, tableName); if (table == null) { throw new Exception(String.format("没有找到表：%s", tableName)); } tableName = table.getTableName(); // 处理包 sb.append("package ").append(packageName).append(";"); sb.append(CRLF).append(CRLF); String daoName = packageName.replace(DAO_IMPL, DAO); daoName += "." + firstToUpper(tableName) + "DAO"; sb.append("import ").append(daoName); sb.append(";").append(CRLF).append(CRLF); String beanName = packageName.replace(DAO_IMPL, ENTITY); beanName += "." + firstToUpper(tableName); sb.append("import ").append(beanName); sb.append(";").append(CRLF).append(CRLF); // java.util集合包导入 // java.sql包导入 sb.append("import java.util.List;").append(CRLF); sb.append("import java.util.ArrayList;").append(CRLF); sb.append("import java.sql.Connection;").append(CRLF); sb.append("import java.sql.PreparedStatement;").append(CRLF); sb.appen