A股上市公司传智教育（股票代码 003032）旗下技术交流社区北京昌平校区

传智教育官网黑马程序员官网

 找回密码
 加入黑马

QQ登录

只需一步，快速开始

论坛首页 › 隐藏归类 › 黑马那些年 › 第32,33,34,35届Android交流区 › 正文

谁有JDBC操作数据库的操作帮助类？

© 时光♪微凉 中级黑马   /  2014-5-8 22:23  /  1432 人查看  /  4 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

本帖最后由 时光♪微凉 于 2014-5-10 17:52 编辑

加必要说明的注释，谢谢！

4 个回复

倒序浏览
周大侠 中级黑马 2014-5-8 23:14:35
| 只看该作者
沙发
  1. import java.sql.*;
  2. public class Test_JDBC1{
  3.   public static void main(String args[])throws Exception{
  4.         try{
  5.                  Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
  6.                  System.out.println("加载数据库驱动程序成功");
  7.                  
  8.                 }
  9.                 catch(Exception e)
  10.                 {
  11.                         System.out.println("无法加载数据库驱动程序");       
  12.                 }
  13.                 //创建数据库连接
  14.                 try{
  15.                         Connection conn= DriverManager.getConnection("jdbc:sqlserver://localhost:1433;DatabaseName=students","tct","123456");
  16.                     
  17.                         if(!conn.isClosed())
  18.                       System.out.println("数据库连接成功！");
  19.         //为了执行SQL语句，创建一个语句对象(Statement是一个接口），通过语句对象来执行一条SQL语句
  20.                         Statement st=conn.createStatement();
  21.                         //获取数据的记录
  22.                 String query="select * from Table1";
  23.                         //使用executeQuery()方法执行SQL命令
  24.                 ResultSet        rs=st.executeQuery(query);
  25.                 System.out.println("*************************");
  26.                 while(rs.next())
  27.                 {                       
  28.                         System.out.print(rs.getString("name")+"  ");
  29.                         System.out.print(rs.getInt("age")+"  ");
  30.                         System.out.println(rs.getString("sex")+"  ");
  31.                 }
  32.                 String sql="insert into Table1 values('Tom','20','man')";
  33.                 int  numberOfRows = st.executeUpdate(sql);
  34.        //String strUpdate="UPDATE Table1 SET name='tct4'";       
  35.        //int rows=st.executeUpdate(strUpdate);
  36.     //        System.out.println("数据库表中的"+rows+"行被修改了");

  38.        //String strDelete="DELETE FROM Table1 WHERE name='Tom'";
  39.       // int  numberOfRows = st.executeUpdate(strDelete);
  40.        //如果记录为空，加入十条记录
  41.   /*        if(resultSet.getInt()==0)
  42.                   for(int i=1;i<11;i++)
  43.                         String sql="insert into faqs value"*/
  44.       //执行查询（select）语句，将结果放入到结果集ResultSe（接口）中        */
  45.             query="select * from Table1";
  46.                         //使用executeQuery()方法执行SQL命令
  47.             rs=st.executeQuery(query);
  48.                 System.out.println("*************************");
  49.                 while(rs.next())
  50.                 {
  51.                         System.out.print(rs.getString("name")+"  ");
  52.                         System.out.print(rs.getInt("age")+"  ");
  53.                         System.out.println(rs.getString("sex")+"  ");
  54.                 }
  55.                 rs.close();
  56.                 st.close();
  57.                 conn.close();
  58.                    }
  59.                 catch(SQLException ee)
  60.                   {
  61.                         System.out.println("数据库连接失败！或存在其他问题");
  62.                    }
  63.        
  64.         }
  65. }
  66. 你看看有用没？
复制代码
回复 使用道具 举报
itpower 高级黑马 2014-5-8 23:30:26
| 只看该作者
藤椅
DBUtils?c3p0?
回复 使用道具 举报
时光♪微凉 中级黑马 2014-5-9 07:52:28
| 只看该作者
板凳
周大侠 发表于 2014-5-8 23:14

感觉这个不是我想要的那个，我想的是在我对数据库执行增删改查操作时，可以调用JDBC帮助类的方法，传入必要的参数，得到想要的结果，就是可以提高代码复用性的那种
回复 使用道具 举报
时光♪微凉 中级黑马 2014-5-10 10:16:55
| 只看该作者
报纸
嘿嘿,自己整了一个数据连接帮助类,看看还能优化没
  1. package basedao;

  3. import java.sql.CallableStatement;
  4. import java.sql.Connection;
  5. import java.sql.DriverManager;
  6. import java.sql.PreparedStatement;
  7. import java.sql.ResultSet;
  8. import java.sql.SQLException;

  10. /**
  11. * 数据库连接于关闭工具类
  12. *
  13. * @author Administrator
  14. *
  15. */
  16. public class BaseDao {
  17.         //数据库驱动字符串
  18.         private String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
  19.         //连接URL字符串
  20.         private String url = "jdbc:sqlserver://localhost:1433;DataBaseName=Message";
  21.         //数据库用户名
  22.         private String user = "sa";
  23.         //用户密码
  24.         private String password = "1213";
  25.         /**
  26.          * 数据连接对象
  27.          */
  28.         protected Connection conn;
  29.         /**
  30.          * 数据操作对象
  31.          */
  32.         protected PreparedStatement ps;
  33.         /**
  34.          * 存储过程操作对象
  35.          */
  36.         protected CallableStatement cs;
  37.         /**
  38.          * 结果集
  39.          */
  40.         protected ResultSet rs;
  41.         /**
  42.          * 创建数据连接对象
  43.          */
  44.         public Connection openConnection() {
  45.                 if (conn == null)
  46.                         try {
  47.                                 Class.forName(driver);
  48.                                 conn = DriverManager.getConnection(url, user, password);
  49.                         } catch (Exception e) {
  50.                                 e.printStackTrace();
  51.                         }
  52.                 return conn;
  53.         }
  54.         /**
  55.          * 关闭数据连接
  56.          */
  57.         public void closeConnection() {
  58.                 if (rs != null)
  59.                         try {
  60.                                 rs.close();
  61.                         } catch (SQLException e) {
  62.                                 e.printStackTrace();
  63.                         }
  64.                 if (ps != null)
  65.                         try {
  66.                                 ps.close();
  67.                         } catch (SQLException e) {
  68.                                 e.printStackTrace();
  69.                         }
  70.                 if (conn != null)
  71.                         try {
  72.                                 conn.close();
  73.                         } catch (SQLException e) {
  74.                                 e.printStackTrace();
  75.                         }
  76.         }
  77.         /**
  78.          * 关闭数据连接
  79.          */
  80.         public void closeConnection(Connection conn, PreparedStatement ps, ResultSet rs) {
  81.                 if (rs != null)
  82.                         try {
  83.                                 rs.close();
  84.                         } catch (SQLException e) {
  85.                                 e.printStackTrace();
  86.                         }
  87.                 if (ps != null)
  88.                         try {
  89.                                 ps.close();
  90.                         } catch (SQLException e) {
  91.                                 e.printStackTrace();
  92.                         }
  93.                 if (conn != null)
  94.                         try {
  95.                                 conn.close();
  96.                         } catch (SQLException e) {
  97.                                 e.printStackTrace();
  98.                         }
  99.         }
  100.         /**
  101.          * 增删改操作
  102.          */
  103.         public int executeIDS(String preparedSql, Object... param) {
  104.                 openConnection();
  105.                 try {
  106.                         ps = conn.prepareStatement(preparedSql);
  107.                         if (param != null)
  108.                                 for (int i = 0; i < param.length; i++) {
  109.                                         // 给Sql语句中的参数赋值
  110.                                         ps.setObject(i + 1, param[i]);
  111.                                 }
  112.                         return ps.executeUpdate();
  113.                 } catch (Exception e) {
  114.                         e.printStackTrace();
  115.                         return -1;
  116.                 } finally {
  117.                         closeConnection();
  118.                 }
  119.         }
  120.         /**
  121.          * 查询操作
  122.          */
  123.         public ResultSet findTable(String preparedSql, Object... param) {
  124.                 openConnection();
  125.                 try {
  126.                         ps = conn.prepareStatement(preparedSql);
  127.                         if (param != null)
  128.                                 for (int i = 0; i < param.length; i++) {
  129.                                         // 给Sql语句中的参数赋值
  130.                                         ps.setObject(i + 1, param[i]);
  131.                                 }
  132.                         return ps.executeQuery();
  133.                 } catch (Exception e) {
  134.                         e.printStackTrace();
  135.                         return null;
  136.                 }//这后面应该不用关闭,关闭了数据库就无法返回ResultSet结果了
  137.         }
  138. }
复制代码
回复 使用道具 举报
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 加入黑马