JDBC的详细讲解和注意事项

 

• JDBC简单一句话，就是用java代码去控制数据库，对数据库进行增删改查
  
• JDBC 的相关API 总结
  
• 最常用是阿里巴巴的德鲁伊数据库连接池技术
  
• 数据库连接步骤
  

• 必须先创建数据库哈
  
• 引入德鲁伊的jar包
  
• 加入配置文件(properties),要放在src目录下，根据一些提示信息去做相应的配置，如果是web程序，需要用properties
  
• 1. JDBCUtilsByDruid工具类连接数据库

  复制代码
  1. package com.yc.ajax.Utils;
  3. import com.alibaba.druid.pool.DruidDataSourceFactory;
  5. import javax.sql.DataSource;
  6. import java.io.FileInputStream;
  7. import java.sql.Connection;
  8. import java.sql.ResultSet;
  9. import java.sql.SQLException;
  10. import java.sql.Statement;
  11. import java.util.Properties;
  13. /**
  14. * 连接数据库
  15. */
  16. public class JDBCUtilsByDruid {
  18.     private static DataSource ds;
  21.     //在静态代码块完成 ds初始化
  22.     static {
  23.         Properties properties = new Properties();
  24.         try {
  25.             //目前我们是javaweb方式启动，所以要获得src目录下的文件，需要用类加载器
  26.             properties.load(JDBCUtilsByDruid.class.getClassLoader().getResourceAsStream("druid.properties"));
  27.             ds = DruidDataSourceFactory.createDataSource(properties);
  28.         } catch (Exception e) {
  29.             e.printStackTrace();
  30.         }
  32.     }
  34.     //编写getConnection方法
  35.     public static Connection getConnection() throws SQLException {
  36.         return ds.getConnection();
  37.     }
  39.     //关闭连接, 老师再次强调： 在数据库连接池技术中，close 不是真的断掉连接
  40.     //而是把使用的Connection对象放回连接池
  41.     public static void close(ResultSet resultSet, Statement statement, Connection connection) {
  43.         try {
  44.             if (resultSet != null) {
  45.                 resultSet.close();
  46.             }
  47.             if (statement != null) {
  48.                 statement.close();
  49.             }
  50.             if (connection != null) {
  51.                 connection.close();
  52.             }
  53.         } catch (SQLException e) {
  54.             throw new RuntimeException(e);
  55.         }
  56.     }
  57. }

  复制代码
   
  
• 1. BasicDao 根据连接的数据库 用德鲁伊去处理改查

  复制代码
  1. package com.yc.ajax.dao;
  3. import com.yc.ajax.Utils.JDBCUtilsByDruid;
  4. import org.apache.commons.dbutils.QueryRunner;
  5. import org.apache.commons.dbutils.handlers.BeanHandler;
  6. import org.apache.commons.dbutils.handlers.BeanListHandler;
  7. import org.apache.commons.dbutils.handlers.ScalarHandler;
  9. import java.sql.Connection;
  10. import java.sql.SQLException;
  11. import java.util.List;
  13. /**
  14. *  根据连接的数据库 用德鲁伊去处理改查
  15. * @param <T>
  16. */
  17. public class BasicDAO<T> {//泛型指定具体类型 需要创建一个javabean
  18.     private QueryRunner qr = new QueryRunner();
  20.     //开发通用的 dml 针对任意的表
  21.     //改
  22.     public int update(String sql, Object... parameters) {
  23.         Connection connection = null;
  24.         try {
  25.             connection = JDBCUtilsByDruid.getConnection();
  27.             int update = qr.update(connection, sql, parameters);
  28.             return update;
  29.         } catch (SQLException e) {
  30.             throw new RuntimeException();
  31.         } finally {
  32.             JDBCUtilsByDruid.close(null, null, connection);
  33.         }
  34.     }
  36.     //返回多个对象(即查询的结果是多行), 针对任意表
  37.     /**
  38.      * @param sql        sql 语句，可以有 ?
  39.      * @param clazz      传入一个类的 Class 对象 比如 Actor.class
  40.      * @param parameters 传入 ? 的具体的值，可以是多个
  41.      * @return 根据 Actor.class 返回对应的 ArrayList 集合
  42.      */
  44.     public List<T> queryMulti(String sql, Class<T> clazz, Object... parameters) {
  45.         Connection connection = null;
  47.         try {
  48.             connection = JDBCUtilsByDruid.getConnection();
  49.             List<T> query = qr.query(connection, sql, new BeanListHandler<T>(clazz), parameters);
  50.             return query;
  51.         } catch (SQLException e) {
  52.             throw new RuntimeException(e);
  53.         } finally {
  54.             JDBCUtilsByDruid.close(null, null, connection);
  55.         }
  56.     }
  59.     //查询单行结果 的通用方法
  60.     public T querySingle(String sql, Class<T> clazz, Object... parameters) {
  61.         Connection connection = null;
  62.         try {
  63.             connection = JDBCUtilsByDruid.getConnection();
  64.             return qr.query(connection,sql, new BeanHandler<T>(clazz), parameters);
  65.         } catch (SQLException e) {
  66.             throw new RuntimeException(e);
  67.         } finally {
  68.             JDBCUtilsByDruid.close(null, null, connection);
  69.         }
  70.     }
  72.     //查询单行单列的方法,即返回单值的方法
  73.     public Object queryScalar(String sql, Object... parameters) {
  74.         Connection connection = null;
  76.         try {
  77.             connection = JDBCUtilsByDruid.getConnection();
  78.             return qr.query(connection,sql,new ScalarHandler(),parameters);
  79.         } catch (SQLException e) {
  80.             throw new RuntimeException(e);
  81.         }finally {
  82.             JDBCUtilsByDruid.close(null,null,connection);
  83.         }
  84.     }
  85. }

  复制代码
   
  
•  UserDao 然后再去继承 BasicDao 范型是一个javabean
  1. package com.yc.ajax.dao;
  3. import com.yc.ajax.entity.User;
  5. public class UserDao extends BasicDAO<User>{
  6. }

  复制代码
   
  
• UserServict 去创建 UserDao的实例然后咱根据业务逻辑调用里面改或者查的方法
  1. import com.yc.ajax.dao.UserDao;
  2. import com.yc.ajax.entity.User;
  4. public class UserServlet {
  6.     private UserDao userDao = new UserDao();
  8.     public User getUserByName(String username){
  10.         User user = userDao.querySingle("select * from user1 where name=?", User.class, username);
  11.         return user;
  12.     }
  13. }

  复制代码
• 最后拿到返回的结果进行判断或者修改数据库
  1. public class CheckUserServlet extends HttpServlet {
  3.     private UserServlet userServlet = new UserServlet();
  4.     @Override
  5.     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  6.         System.out.println("CheckUserServlet .. 被调用");
  8.         response.setContentType("text/html;charset=utf-8");
  9.         //接收 ajax 提交的数据
  10.         String username = request.getParameter("username");
  11. //        if ("king".equals(username)){
  12. //            User king = new User(100, "king", "king@qq.com", "12345");
  13. //            String user_king = new Gson().toJson(king);
  14. //            response.getWriter().write(user_king);
  15. //        }else {
  16. //            response.getWriter().write("");
  17. //        }
  18.         User userByName = userServlet.getUserByName(username);
  19.         if (userByName != null){ //说明用户已经存在
  20.             //返回一个json
  21.             Gson gson = new Gson();
  22.             String s = gson.toJson(userByName);
  23.             response.getWriter().write(s);
  24.         }else {
  25.             response.getWriter().write("");
  26.         }
  29.     }
  31.     @Override
  32.     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  33.         doGet(request,response);
  34.     }
  35. }

  复制代码
   
  

 
 

 
 

 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！