笔者本人真正意义上接触编程开发是在2004年，最早用的就是VB，然后是Delphi等，后来转到.Net，中间断断续续还用过PowerBuilder等，无一例外，所研发设计的项目或系统都是WinForm应用程序，基于C/S模式的窗口应用程序开发那个时候还是正道，而Web开发还没有现在这么红火，技术也没有现在这么多姿多彩。
后来，B/S技术日渐成熟起来，jquery、node.js、flex、spring、structs、hibernate等技术框架相继涌现出来，进行Web开发的门槛降了下来，开发效率提高了许多，C/S开发慢慢地受到了冷落。
不过，在闲暇之余，笔者本人仍会时常设计一些窗口小程序，或者用WinForm程序开发的方式测试Web开发中遇到的算法问题。尤其是有些时候，笔者仅仅是想测试一个类或者接口方法，如果在Web工程中编码测试的话，你就要配置一大堆东西，最后还要启动个IIS，或者Tomcat，或者JBoss什么的，破费周折；当然了，你也可以脱离Web工程环境，写个类似dos的小程序也行，不过那样的话人机交互性实在太差劲。就好像下面这个窗口：
就以上弊病而言，WinForm开发算是有得天独厚的优势了，考虑到跨平台的问题，再加上最近一年笔者都在持续地研究大数据方面的技术，基本上都是在用java进行技术研发和探索，所以很自然地，Swing就成了首选技术。
感觉Swing好像被冷落了好多年了，这也难怪，从当初的JCreator、JBuilder到NetBean，以及现在的Eclipse等，C/S开发好像都是非主流的，B/S才是主流，而且RAD特性也远远没有微软的VS好。好在有一点它是非常突出的，那就是跨平台，可以轻松部署在Linux系统中。
经过最近半年多试用Swing，笔者慢慢地积累了一些东西，断断续续的，偏偏面面的，各位不要太过于责怪，笔者会尽量将其归类整理，并给出相关的运行实例程序代码。
首先，在前面几个章节，我们会构建个Java基础功能包，介绍一些设计实现思路，封装设计一些接口方法，作为我们进行Swing应用开发的基础，有了这个基础功能包，我们接下来的Swing开发会有事半功倍的效果。
1、自定义JdbcTemplate
Hibernate中的JdbcTemplate组件功能已经很强悍了，不过现在我们要自定义设计个轻量级别的JdbcTemplate组件，作为我们Swing开发的基础功能包的一部分。我们主要对常用的关系数据库进行接口封装，包括Oracle和MySql两种数据库。
1.1 数据库类型枚举类
/** * Description: 数据库类型。 * Copyright: Copyright (c) 2015 * Company: 河南电力科学研究院智能电网所 * @author shangbingbing 2015-01-01编写 * @version 1.0 */public enum DBType { ORACLE, MYSQL} 1.2 数据库JDBC操作类
/** * Description: 关系数据库数据操作接口模板。 * Copyright: Copyright (c) 2015 * Company: 河南电力科学研究院智能电网所 * @author shangbingbing 2015-01-01编写 * @version 1.0 */public class JdbcTemplate { private DBType dataBaseType = DBType.ORACLE; private String userName = ""; private String password = ""; private String driver = ""; private String connectionUrl = ""; /** * 获取数据库用户名称 * @return */ public String getUserName() { return this.userName; } /** * 设置数据库用户名称 * @param userName */ public void setUserName(String userName) { this.userName = userName; } /** * 获取数据库用户密码 * @return */ public String getPassword() { return this.password; } /** * 设置数据库用户密码 * @param password */ public void setPassword(String password) { this.password = password; } /** * 获取数据库驱动程序 * @return */ private String getDriver() { if(this.dataBaseType == DBType.ORACLE) { this.driver = "oracle.jdbc.driver.OracleDriver"; } else if (this.dataBaseType == DBType.MYSQL) { this.driver = "com.mysql.jdbc.Driver"; } return driver; } /** * 获取数据库连接URL * @return */ public String getConnectionUrl() { return this.connectionUrl; } /** * 设置数据库连接URL * @param url */ public void setConnectionUrl(String url) { this.connectionUrl = url; } /** * 默认构造函数。 * @param dataBaseType */ public JdbcTemplate() { } /** * 构造函数，并确定数据库类型。 * @param dataBaseType */ public JdbcTemplate(DBType dataBaseType) { this.dataBaseType = dataBaseType; } /** * 数据库连接对象 */ private Connection conn = null; /** * 获取数据库连接对象 * @return */ public Connection getConnection() { try { if(this.conn == null || this.conn.isClosed()) { Class.forName(this.getDriver()); this.conn = DriverManager.getConnection(getConnectionUrl(),getUserName(),getPassword()); } } catch (Exception e) { e.printStackTrace(); } return this.conn; } /** * SQL语句对象 */ private Statement stmt = null; /** * 执行增删改SQL语句 * @param strSql * @return */ public boolean executeSql(String strSql) { if(strSql == null || strSql.isEmpty()) { return false; } try { LogInfoUtil.printLog(strSql); this.stmt = this.getConnection().createStatement(); this.stmt.execute(strSql); //execute返回值出现问题，即使SQL执行成功也会返回false的。 return true; } catch(Exception e) { e.printStackTrace(); return false; } } /** * 批量执行增删该SQL语句 * @param strSqlList */ public void executeSql(List strSqlList) { if(strSqlList == null || strSqlList.size() == 0) { return; } try { this.stmt = this.getConnection().createStatement(); //每500作为一个插入批量操作 int batchSize = 500; int count = 0; for(String strSql : strSqlList) { LogInfoUtil.printLog(strSql); this.stmt.addBatch(strSql); if(++count % batchSize == 0) { this.stmt.executeBatch(); } } //插入剩余的数据 this.stmt.executeBatch(); } catch(Exception e) { e.printStackTrace(); } } /** * 获取SQL检索语句结果集中的列名称及类型信息。 * @param strSql * @return */ public TreeMap getColumnTypeList(String strSql) { TreeMap columnTypeList = new TreeMap (); try { LogInfoUtil.printLog(strSql); this.stmt = this.getConnection().createStatement(); ResultSet rs = this.stmt.executeQuery(strSql); //获取数据集的列信息 ResultSetMetaData rsmd = rs.getMetaData(); int columnCount = rsmd.getColumnCount(); for(int i=1; i<=columnCount; i++) { String columnName = rsmd.getColumnName(i); columnTypeList.put(columnName,rsmd.getColumnType(i)); } rs.close(); return columnTypeList; } catch(Exception e) { e.printStackTrace(); return columnTypeList; } } /** * 获取SQL检索语句结果集中的列名称及类型信息。 * @param strSql * @return */ public TreeMap getColumnTypeNameList(String strSql) { TreeMap columnTypeList = new TreeMap (); try { LogInfoUtil.printLog(strSql); this.stmt = this.getConnection().createStatement(); ResultSet rs = this.stmt.executeQuery(strSql); //获取数据集的列信息 ResultSetMetaData rsmd = rs.getMetaData(); int columnCount = rsmd.getColumnCount(); for(int i=1; i<=columnCount; i++) { String columnName = rsmd.getColumnName(i); columnTypeList.put(columnName,rsmd.getColumnTypeName(i)); } rs.close(); return columnTypeList; } catch(Exception e) { e.printStackTrace(); return columnTypeList; } } /** * 执行SQL查询语句,将结果以List 形式组装返回. * @param strSql * @return */ public List executeQuery(String strSql) { List propertiesList = new ArrayList (); if(strSql == null || strSql.isEmpty()) { return propertiesList; } try { LogInfoUtil.printLog(strSql); this.stmt = this.getConnection().createStatement(); ResultSet rs = this.stmt.executeQuery(strSql); //获取数据集的列信息 ResultSetMetaData rsmd = rs.getMetaData(); HashMap columnList = new HashMap (); int columnCount = rsmd.getColumnCount(); for(int i=1; i<=columnCount; i++) { String columnName = rsmd.getColumnName(i); columnList.put(columnName,rsmd.getColumnType(i)); } while(rs.next()) { Properties properties = new Properties(); for(String columnLabel : columnList.keySet()) { int columnType = columnList.get(columnLabel); Object columnValue = null; switch (columnType) { case Types.VARCHAR : columnValue = rs.getString(columnLabel); break; case Types.NUMERIC: columnValue = rs.getBigDecimal(columnLabel); break; case Types.DATE: columnValue = rs.getDate(columnLabel).toString() + " " + rs.getTime(columnLabel).toString(); break; case Types.NVARCHAR: columnValue = rs.getNString(columnLabel); break; case Types.DECIMAL: columnValue = rs.getBigDecimal(columnLabel); break; case Types.FLOAT: columnValue = rs.getFloat(columnLabel); break; case Types.DOUBLE: columnValue = rs.getDouble(columnLabel); break; case Types.BOOLEAN: columnValue = rs.getBoolean(columnLabel); break; case Types.INTEGER: columnValue = rs.getInt(columnLabel); break; case Types.BIGINT: columnValue = rs.getLong(columnLabel); break; case Types.TIME: columnValue = rs.getTime(columnLabel); break; case Types.BLOB: columnValue = rs.getBlob(columnLabel); break; case Types.CLOB: columnValue = rs.getClob(columnLabel); break; default: columnValue = rs.getObject(columnLabel); break; } if(columnValue == null) { properties.put(columnLabel, ""); } else { properties.put(columnLabel, columnValue); } } propertiesList.add(properties); } rs.close(); return propertiesList; } catch(Exception e) { e.printStackTrace(); return propertiesList; } } /** * 获取指定表中的记录总数 * @param tableName 指定表名称 * @return 表中的记录总数 */ public int getTableRecordTotalCount(String tableName) { int totalCount = 0; String strSql = "select count(rowid) as RECORD_COUNT from " + tableName; try { LogInfoUtil.printLog(strSql); this.stmt = this.getConnection().createStatement(); ResultSet rs = this.stmt.executeQuery(strSql); while(rs.next()) { totalCount = rs.getInt("RECORD_COUNT"); } rs.close(); } catch (Exception e) { e.printStackTrace(); } return totalCount; }/** * 释放连接资源 */ public void close() { try { if(this.stmt != null) { this.stmt.close(); this.stmt = null; } if(this.conn != null) { this.conn.close(); this.conn = null; } } catch (Exception e) { e.printStackTrace(); } } /** * 读取指定的JDBC Properties文件，初始化数据连接信息。 * @param jdbcPropertiesFile */ public void initJdbcTemplate(String jdbcPropertiesFile) { HashMap pps = PropertiesUtil.readProperties(jdbcPropertiesFile); String url = pps.get("jdbc.url"); String userName = pps.get("jdbc.username"); String password = pps.get("jdbc.password"); this.connectionUrl = url; this.userName = userName; this.password = password; }} 我们仅仅设计了几个常用的接口方法，看官可以根据自己的实际需要进行丰富和完善，譬如可以增加读写Blob字段的功能等等。
1.3 应用开发实例
- 操作Oracle数据库
JdbcTemplate jdbcTemplate = new JdbcTemplate();或者JdbcTemplate jdbcTemplate = new JdbcTemplate(DBType.ORACLE);jdbcTemplate.setConnectionUrl(“jdbc:oracle:thin:@ ......”);jdbcTemplate.setUserName(“admin”);jdbcTemplate.setPassword(“admin”); String strSql = "SELECT * FROM SYSTEM_USER";Listlist = jdbcTemplate.executeQuery(strSql);
- 操作MySql数据库
JdbcTemplate jdbcTemplate = new JdbcTemplate(DBType.MYSQL);jdbcTemplate.setConnectionUrl(“jdbc:mysql://10.231.45.34 ......”);jdbcTemplate.setUserName(“admin”);jdbcTemplate.setPassword(“admin”);String strSql = "SELECT * FROM SYSTEM_USER";Listlist = jdbcTemplate.executeQuery(strSql);
【完】
作者：商兵兵
单位：河南省电力科学研究院智能电网所
QQ：52190634
主页：
空间：