学步园

 简单的Java测试类

package com.common.db;</p> <p>import java.sql.Connection;<br /> import java.sql.DriverManager;<br /> import java.sql.ResultSet;<br /> import java.sql.SQLException;<br /> import java.sql.Statement;</p> <p>/**<br /> * @title 数据库操作<br /> * @description 数据库操作<br /> * @since Java5<br /> */<br /> public class JDBCUtil {</p> <p> private JDBCUtil() {<br /> }</p> <p> static {<br /> try {<br /> String driver = "com.ibm.db2.jcc.DB2Driver";<br /> // 装载驱动<br /> Class.forName(driver);<br /> } catch (ClassNotFoundException e) {<br /> throw new ExceptionInInitializerError(e);<br /> } catch (Exception ex) {<br /> throw new RuntimeException("database driver load error");<br /> }<br /> }</p> <p> /**<br /> * 获取数据库连接<br /> * @param url url<br /> * @param user 用户名<br /> * @param password 密码<br /> * @return 数据库连接<br /> * @throws SQLException<br /> */<br /> public static Connection getConnection(String url, String user, String password) throws SQLException {</p> <p> return DriverManager.getConnection(url, user, password);<br /> }</p> <p> /**<br /> * 释放数据库相关对象<br /> *<br /> * @param rs 结果集<br /> * @param st 声明<br /> * @param conn 连接<br /> */<br /> public static void free(ResultSet rs, Statement st, Connection conn) {<br /> try {<br /> if (rs != null) {<br /> rs.close();<br /> }<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> } finally {<br /> try {<br /> if (st != null) {<br /> st.close();<br /> }<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> } finally {<br /> if (conn != null) {<br /> try {<br /> if (!conn.isClosed()) {<br /> conn.close();<br /> }<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }<br /> }<br /> }</p> <p> public static void main(String[] args) {<br /> Connection conn = null;<br /> Statement st = null;<br /> ResultSet rs = null;</p> <p> try {<br /> conn = JDBCUtil.getConnection("jdbc:db2://localhost:50000/CONTENT", "administrator", "abcde");<br /> st = conn.createStatement();<br /> String sql = "select * from user_information";<br /> rs = st.executeQuery(sql);<br /> while(rs.next()) {<br /> System.out.println(rs.getString(1));<br /> }<br /> System.out.println("test for connection correct");<br /> } catch (SQLException e) {<br /> // 添加日志记录该异常<br /> e.printStackTrace();<br /> System.out.println("test for connection exception");<br /> } finally {<br /> JDBCUtil.free(rs, st, conn);<br /> }</p> <p> }<br /> }<br />

1<br /> test for connection correct<br />