JDBC工具类.docVIP

package com.shxt.sheji.tools; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.Statement; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; public class JDBCTools { Connection conn = null; Statement stmt = null; PreparedStatement pstmt = null; ResultSet rs = null; static String driver = com.mysql.jdbc.Driver; String url = jdbc:mysql://localhost:3308/jinxiu7; String user = root; String password = mysql; /** * 驱：用静态代码块加载驱动，只序执行一次。 */ static { try { Class.forName(driver); } catch (Exception e) { e.printStackTrace(); System.out.println(加载驱动出错。); } } /** * 连：建立连接。 * @return Connection */ public Connection getConnection(){ try { return DriverManager.getConnection(url, user, password); } catch (Exception e) { e.printStackTrace(); System.out.println(建立连接出错。); return null; } } /** * 句：创建语句对象。 * @return Statement */ public Statement getStatement() { try { conn = getConnection(); return conn.createStatement(); } catch (Exception e) { e.printStackTrace(); return null; } } /** * 执行 SQL 增 、删、改 * @param sql 语句。 * @return 影响行数。（失败返回-1） */ public int myUpdate(String sql) { int i = -1; try { stmt = getStatement(); i = stmt.executeUpdate(sql); } catch (Exception e) { e.printStackTrace(); System.out.println(增 、删、改 SQL语句执行错误。); } closeAll(); //关闭资源！ return i; } /*以数组形式输出结果集**/ public ListString[] query(String sql) { ListString[] rsList = new ArrayListString[](); try { stmt = getStatement(); ResultSet rs = stmt.executeQuery(sql); ResultSetMetaData rsmd = rs.getMetaData(); while (rs.next()) { //rs每next一次，将获取一条记录，用一个数组表示一条 String[] tempArray = new String[rsmd.getColumnCount()]; //循环对新产生的数组进行赋值 for (int i = 1; i = rsmd.getColumnCou