学步园

下面是DB类，也就是数据库连接及操作类：

package com.ljh.util;</p> <p>import java.sql.Connection;<br /> import java.sql.Date;<br /> import java.sql.DriverManager;<br /> import java.sql.PreparedStatement;<br /> import java.sql.ResultSet;<br /> import java.sql.SQLException;<br /> import java.sql.Statement;</p> <p>public class DB {</p> <p> /*以下是定义一些字段*/<br /> private String url = "jdbc:mysql://localhost:3306/dao?user=root&password=1814"; //数据库URL<br /> private String className = "com.mysql.jdbc.Driver"; //数据库驱动类路径<br /> private Connection conn = null; //声明一个Connection对象<br /> private Statement stmt = null; //声明一个Statement对象<br /> private PreparedStatement pstmt = null; //声明一个PreparedStatement对象</p> <p> /*初始化一些东西：加载数据库驱动，并建立连接*/<br /> public void init(){<br /> try {<br /> //加载数据库驱动<br /> Class.forName(className).newInstance();<br /> //建立连接，连接到由属性url指定的数据库URL，并指定登录数据库的用户名和密码<br /> conn = DriverManager.getConnection(url);<br /> //在初始化方法里面首先获取Statement对象<br /> stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY );<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> System.out.println("初始化方法init()出现错误，加载数据库驱动失败 或者 建立连接失败！！");<br /> }<br /> }</p> <p> /*构造方法*/<br /> public DB(){<br /> init();<br /> }</p> <p> /*********************************以下方法是针对Statement的****************************************/</p> <p> /*查询数据库，返回结果集ResultSet*/<br /> public ResultSet executeQuery(String sql){<br /> ResultSet rs = null;<br /> try {<br /> rs = stmt.executeQuery(sql);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("executeQuery(String sql)方法出错！！");<br /> }<br /> return rs;<br /> }</p> <p> /*对数据库中的数据进行增加、修改或删除，返回受影响的行数*/<br /> public int executeUpdate(String sql){<br /> int iCount = 0;<br /> try {<br /> iCount = stmt.executeUpdate(sql);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("executeUpdate(String sql)方法出错！！");<br /> }<br /> return iCount;<br /> }</p> <p> /*********************************以下方法是针对PreparedStatement的****************************/</p> <p> /*依据SQL语句给pstmt赋上值*/<br /> public void readyPreparedStatement(String sql){<br /> try {<br /> pstmt = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY );<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("readyPreparedStatement()方法出错！！");<br /> }<br /> }</p> <p> /*以下是一些 PreparedStatement 设置的方法*/<br /> public void setString(int index, String value){<br /> try {<br /> pstmt.setString(index, value);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("PreparedStatement的设置方法setString()出错！！");<br /> }<br /> }<br /> public void setInt(int index, int value){<br /> try {<br /> pstmt.setInt(index, value);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("PreparedStatement的设置方法setInt()出错！！");<br /> }<br /> }<br /> public void setBoolean(int index, boolean value){<br /> try {<br /> pstmt.setBoolean(index, value);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("PreparedStatement的设置方法setBoolean()出错！！");<br /> }<br /> }<br /> public void setDate(int index, Date value){<br /> try {<br /> pstmt.setDate(index, value);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("PreparedStatement的设置方法setDate()出错！！");<br /> }<br /> }<br /> public void setLong(int index, long value){<br /> try {<br /> pstmt.setLong(index, value);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("PreparedStatement的设置方法setLong()出错！！");<br /> }<br /> }<br /> public void setFloat(int index, float value){<br /> try {<br /> pstmt.setFloat(index, value);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("PreparedStatement的设置方法setFloat()出错！！");<br /> }<br /> }<br /> public void setBytes(int index, byte[] value){<br /> try {<br /> pstmt.setBytes(index, value);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("PreparedStatement的设置方法setBytes()出错！！");<br /> }<br /> }</p> <p> /*查询数据库，返回结果集ResultSet*/<br /> public ResultSet executeQuery(){<br /> if (pstmt != null) {<br /> try {<br /> return pstmt.executeQuery();<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("executeQuery()方法出错！！");<br /> return null;<br /> }<br /> } else{<br /> System.out.println("PreparedStatement 未给定值！！");<br /> return null;<br /> }<br /> }</p> <p> /*对数据库中的数据进行增加、修改或删除，返回受影响的行数*/<br /> public int executeUpdate(){<br /> int iCount = 0;<br /> if (pstmt != null){<br /> try {<br /> iCount = pstmt.executeUpdate();<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("executeUpdate()方法出错！！");<br /> }<br /> } else{<br /> System.out.println("PreparedStatement 未给定值！！");<br /> }<br /> return iCount;<br /> }</p> <p> /*********************************************************************************************************/</p> <p> /*关闭所有连接*/<br /> public void close(){<br /> try {<br /> if (stmt != null) {<br /> stmt.close();<br /> stmt = null;<br /> }<br /> if (pstmt != null) {<br /> pstmt.close();<br /> pstmt = null;<br /> }<br /> if (conn != null) {<br /> conn.close();<br /> }<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> System.out.println("关闭所有连接的方法close()出错了！！");<br /> }<br /> }<br /> }</p> <p>

下面是测试DB类的一个Java小程序(用于往表中插入一条记录，并在插入后，对该表进行查询)：

package com.ljh.util;</p> <p>public class DBTest {<br /> public static void main(String[] args) throws Exception{<br /> String sql = "insert into usertbl(id,username,password) values(?,?,?)";<br /> DB db = new DB();<br /> db.readyPreparedStatement(sql);<br /> db.setInt(1, 5);<br /> db.setString(2, "sss");<br /> db.setString(3,"yyy");<br /> db.executeUpdate();<br /> db.close();<br /> db.init();<br /> db.executeQuery("select * from usertbl");<br /> }<br /> }<br />