当前位置：网站首页 > Java基础 > 正文

java 基础和数据库

Java基础 来源： 网络 编辑：小编 发布时间：2024-10-19 18:18:00 浏览量：15



时间：2024-05-17日，星期五

文章内容

JDBC快速入门、使用JDBC开发细节、连接池与JDBC进阶使用

  • JDBC使用步骤

  • 数据库查询方法

  • 数据库写入方法

  • SQL注入攻击的应对

  • 连接池的使用

  • Apache Commons DBUtils

JDBC快速入门

JDBC是Java中为了去方便使用各种数据库而创造出来的，在java开发过程中可以使用JDBC API进而对不同的数据库进行驱动使用。

JDBC的优点：

  • 统一的API，提供一致的开发过程

  • 易于学习，容易上手，代码结构稳定

  • 功能强大，执行效率高，可处理海量数据

JDBC开发流程

  1. 加载并注册JDBC驱动

  2. 创建数据库连接

  3. 创建Statement对象

  4. 遍历查询结果

  5. 关闭连接，释放资源

    public static void main(String[] args){
         Connection conn=null;
         try {
             //1. 加载并注册JDBC驱动
             Class.forName("com.mysql.cj.jdbc.Driver");
             //2. 创建数据库连接
             conn = DriverManager.getConnection(
                     "jdbc:mysql://localhost:3306/learning_jdbc?serverTimezone=UTC","root","123456"
             );
             //3. 创建Statement对象
             Statement stmt = conn.createStatement();
             ResultSet rs = stmt.executeQuery("SELECT * FROM employee");
             //4. 遍历查询结果
             while(rs.next()){
                 Integer eno= rs.getInt(1);
                 String name = rs.getString("ename");
                 Float salary = rs.getFloat("salary");
                 String dname = rs.getString("dname");
                 Date hiredate = rs.getDate("hiredate");
                 System.out.println(eno+"-"+name+"-"+salary+"-"+dname+"-"+ hiredate);
             }
         }catch (Exception e){
             e.printStackTrace();
         }finally {
             try {
                 //5. 关闭连接，释放资源
                 if (conn != null && conn.isClosed() java 基础和数据库 == false){
                     conn.close();
                 }
             } catch (SQLException throwables) {
                 throwables.printStackTrace();
             }
         }
     }

JDBC开发流程细节

各数据库与连接字符串：

JDBC连接的对象Connection，通过TCP/IP协议，连通JDBC应用(Java程序)与MySQL数据库服务器的3306端口

  //2. 创建数据库连接
             conn = DriverManager.getConnection(
                     "jdbc:mysql://localhost:3306/learning_jdbc?serverTimezone=UTC","root","123456"
             )

其中的参数包括了连接字符串与数据库用户名和密码

MySQL连接字符串：

  • 格式：jdbc:mysql://主机ip：端口/数据库名？参数列表

  • 主机ip与端口是可选设置，默认值为127.0.0.1与3306

  • 参数列表采用url编码，格式：参数1=值1&参数2=值2&..

SQL注入攻击问题：

  • SQL注入攻击是指利用SQL漏洞越权获取数据的黑客行为

  • SQL注入攻击根源是对原始SQL中的敏感字符做特殊处理

  • 解决方法：放弃Statement改用PrepareStatement处理SQL

    • Statement方法对符号单引号没有进行处理，会被SQL注入，使用PreStatement能防范SQL注入。

PrepareStatement

  • PrepareStatement预编译Statement是Statement的子接口

  • PrepareStatement对SQL进行参数化，预防SQL注入攻击

  • PreparedStatement比Statement执行效率更高

  •  String pdname = in.nextLine();
         String pdname = "市场部"；//输入参数
         Connection conn=null;
         try {
             //1. 加载并注册JDBC驱动
             Class.forName("com.mysql.cj.jdbc.Driver");
             //2. 创建数据库连接
             conn = DriverManager.getConnection(
                     "jdbc:mysql://localhost:3306/learning_jdbc?serverTimezone=UTC","root","123456"
             );
             //3. 创建Statement对象
             String sql = "SELECT * FROM employee WHERE dname=?";
             PreparedStatement pStmt = conn.prepareStatement(sql);
             pStmt.setString(1,pdname);
             ResultSet rs = pStmt.executeQuery("SELECT * FROM employee WHERE dname='"+ pdname+"'");
             //4. 遍历查询结果
             while(rs.next()){
                 Integer eno= rs.getInt(1);
                 String name = rs.getString("ename");
                 Float salary = rs.getFloat("salary");
                 String dname = rs.getString("dname");
                 Date hiredate = rs.getDate("hiredate");
                 System.out.println(eno+"-"+name+"-"+salary+"-"+dname+"-"+ hiredate);
             }
         }catch (Exception e){
             e.printStackTrace();
         }finally {
             try {
                 //5. 关闭连接，释放资源
                 if (conn != null && conn.isClosed() == false){
                     conn.close();
                 }
             } catch (SQLException throwables) {
                 throwables.printStackTrace();
             }
         }

时间：2024-05-19日，星期天

JDBC进行数据库操作

将上面的数据库连接和数据库连接资源关闭方法进行封装，得到DBUtils，数据库工具文件

 package com.imooc.jdbc.common;
 ​
 import java.sql.*;
 ​
 public class DBUtils {
     /**
      * 获取数据库连接
      * @return返回数据库连接
      * @throws ClassNotFoundException
      * @throws SQLException
      */
     public static Connection getConnection() throws ClassNotFoundException, SQLException {
         //1. 加载并注册JDBC驱动
         Class.forName("com.mysql.cj.jdbc.Driver");
         //2. 创建数据库连接
         Connection conn = DriverManager.getConnection(
                 "jdbc:mysql://localhost:3306/learning_jdbc?serverTimezone=UTC","root","123456"
         );
         return conn;
     }
 ​
     /**
      * 关闭数据库连接相关资源
      * @param rs 数据库返回结果集
      * @param stmt 数据库预处理查询语句
      * @param conn 数据库连接
      */
     public static void closeConnection(ResultSet rs, Statement stmt, Connection conn){
         if (rs !=null){
             try {
                 //关闭结果连接，释放资源
                 rs.close();
             } catch (SQLException throwables) {
                 throwables.printStackTrace();
             }
         }
         if (stmt != null){
             try {
                 //关闭连接，释放资源
                 stmt.close();
             } catch (SQLException throwables) {
                 throwables.printStackTrace();
             }
         }
         try {
             //5. 关闭连接，释放资源
             if (conn != null && conn.isClosed() == false){
                 conn.close();
             }
         } catch (SQLException throwables) {
             throwables.printStackTrace();
         }
     }
 }

JDBC执行插入操作
 public class InsertCommand implements Command{
     @Override
     public void execute() {
         Scanner in = new Scanner(System.in);
         System.out.println("请输入员工编号:");
         int eno = in.nextInt();
         System.out.println("请输入员工姓名:");
         String ename = in.next();
         System.out.println("请输入员工薪资:");
         float salary = in.nextFloat();
         System.out.println("请输入隶属部门");
         String dname = in.next();
         Connection conn = null;
         PreparedStatement pStmt = null;
         try {
             conn = DBUtils.getConnection();
             String sql = "INSERT INTO employee(eno,ename,salary,dname) VALUES(?,?,?,?)";//插入语句
             pStmt = conn.prepareStatement(sql);
             pStmt.setInt(1,eno);
             pStmt.setString(2,ename);
             pStmt.setFloat(3,salary);
             pStmt.setString(4,dname);
             int cnt = pStmt.executeUpdate();//执行更新方法，返回插入的条数
             System.out.println("数据新增成功条数:"+cnt);
             System.out.println(ename+"已成功办理入职");
         } catch (ClassNotFoundException e) {
             e.printStackTrace();
         } catch (SQLException throwables) {
             throwables.printStackTrace();
         }finally {
             DBUtils.closeConnection(null,pStmt,conn);
         }
     }
 }
 ​
JDBC执行更新和删除操作

//更新

 /调整员工薪资
 public class UpdateCommand implements Command {
     @Override
     public void execute() {
         Scanner in = new Scanner(System.in);
         System.out.println("请输入要调整的员工编号");
         int eno = in.nextInt();
         System.out.println("请输入要调整到的薪资");
         float salary = in.nextFloat();
         Connection conn = null;
         PreparedStatement pStmt = null;
 ​
         try {
             conn = DBUtils.getConnection();
             String sql = "UPDATE employee SET salary=? WHERE eno=?";
             pStmt = conn.prepareStatement(sql);
             pStmt.setFloat(1,salary);
             pStmt.setInt(2, eno);
             int cnt = pStmt.executeUpdate();
             if (cnt == 1){
                 System.out.println("员工编号"+eno+"薪资已调整到"+salary);
             }else{
                 System.out.println("未找到员工编号为:"+eno+"的员工");
             }
         } catch (ClassNotFoundException e) {
             e.printStackTrace();
         } catch (SQLException throwables) {
             throwables.printStackTrace();
         }finally {
             DBUtils.closeConnection(null,pStmt,conn);
         }
     }
 }

//删除

 ​
 public class DeleteCommand implements Command{
     @Override
     public void execute() {
         Scanner in = new Scanner(System.in);
         System.out.println("请输入要删除的员工编号");
         int eno = in.nextInt();
         System.out.println("请输入要删除的员工姓名");
         String enmae = in.next();
         Connection conn = null;
         PreparedStatement pStmt = null;
 ​
         try {
             conn = DBUtils.getConnection();
             String sql = "DELETE FROM employee WHERE eno = ? AND ename = ?";
             pStmt = conn.prepareStatement(sql);
             pStmt.setInt(1,eno);
             pStmt.setString(2,enmae);
             int cnt = pStmt.executeUpdate();
             if (cnt == 1){
                 System.out.println("cnt:"+cnt);
                 System.out.println("员工编号"+eno+"，姓名"+enmae+"的员工已删除");
             }else {
                 System.out.println("员工编号"+eno+"，姓名"+enmae+"的员工未找到");
             }
 ​
         } catch (ClassNotFoundException e) {
             e.printStackTrace();
         } catch (SQLException throwables) {
             throwables.printStackTrace();
         }finally {
             DBUtils.closeConnection(null,pStmt,conn);
         }
     }
 }

更新和删除操作的方法主要区别是sql语句的不同，其它的内容大致相似。

JDBC的事务管理

JDBC中允许两种事务模式，分别是自动提交和手动提交模式

  • 自动提交事务模式

    • 自动提交模式是指每执行一次写操作SQL，自动提交事务

    • 自动提交开启方法：conn.setAutoCommit(true)

    • 自动事务是JDBC默认行为，此模式无法保证多数据一致性

  • 手动提交事务模式

    • 手动提交模式是指显式调用commit()与rollback()方法管理事务

    • 手动提交开启方法;conn.setAutoCommit(flase)

    • 手动提交事务可保证多数据一致性，但必须手动调用提交/回滚方法

//手动提交事务案例

 ​
 //JDBC事务管理，演示案例批量添加员工
 public class TransactionSample {
     public static void main(String[] args) {
         Connection conn = null;
         PreparedStatement pStmt = null;
 ​
         try {
             conn = DBUtils.getConnection();
             conn.setAutoCommit(false);//开启jdbc手动提交事务，，自动提交事务时默认为true
             String sql = "insert into employee(eno,ename,salary,dname) values(?,?,?,?)";
             pStmt = conn.prepareStatement(sql);
             for (int i=1000; i<2000; i++){
                 if (i==1005){
 //                    throw new RuntimeException("插入失败"); //注释后，不抛异常，正常执行
                 }
                 pStmt.setInt(1,i);
                 pStmt.setString(2,"员工"+i);
                 pStmt.setFloat(3,4000f);
                 pStmt.setString(4,"市场部");
                 pStmt.executeUpdate();
             }
             conn.commit();//手动提交情况下才能显式使用
         } catch (Exception e) {
             try {
                 conn.rollback();//回滚数据，手动提交情况下才能使用
             } catch (SQLException throwables) {
                 throwables.printStackTrace();
             }
         } finally {
             DBUtils.closeConnection(null,pStmt,conn);
         }
     }
 }
JDBC对时间类型的处理

//将String类型转为java.sql.Date,分为两步，分别是

         //1.String转为java.util.Date
         java.util.Date udHiredate = null;
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
         try {
             udHiredate = sdf.parse(strHireadate);
         } catch (ParseException e) {
             e.printStackTrace();
         }
         //2.java.util.Date转为java.sql.Date
         long time = udHiredate.getTime();//获取自1970到现在的毫秒数
         java.sql.Date sdHiredate = new java.sql.Date(time);

数据库连接池

阿里巴巴Druid连接池

Druid是阿里巴巴开源连接池组件，Druid对数据库连接进行有效管理与重用，最大化程序执行效率，连接池负责创建管理连接，程序只负责取用与归还

连接Druid连接池（配置和使用）
 //配置使用Druid连接池
 public class DruidSample {
     public static void main(String[] args) {
 ​
         //1.加载属性文件
         Properties properties = new Properties();
         String propertyFile = DruidSample.class.getResource("/druid-config.properties").getPath();
         try {
             propertyFile = new URLDecoder().decode(propertyFile, "UTF-8");//解析文件，避免错误
             properties.load(new FileInputStream(propertyFile));
         } catch (Exception e) {
             e.printStackTrace();
         }
         Connection conn = null;
         PreparedStatement pStmt = null;
         ResultSet rs = null;
 ​
         try {
             //2.获取DataSource数据源对象
             DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
             //创建数据库连接
             conn = dataSource.getConnection();
             pStmt = conn.prepareStatement("select * from employee limit 0,5");
             rs = pStmt.executeQuery();
             while(rs.next()){
                 Integer eno= rs.getInt(1);
                 String name = rs.getString("ename");
                 Float salary = rs.getFloat("salary");
                 String dname = rs.getString("dname");
                 Date hiredate = rs.getDate("hiredate");
                 System.out.println(eno+"-"+name+"-"+salary+"-"+dname+"-"+ hiredate);
             }
         } catch (Exception e) {
             e.printStackTrace();
         }finally {
             DBUtils.closeConnection(rs,pStmt,conn);
         }
 ​
     }
 }

Apache Commons DBUtils

版权声明：

本文来源网络，所有图片文章版权属于原作者，如有侵权，联系删除。


本文网址：https://www.bianchenghao6.com/h6javajc/25735.html

相关文章：

  • java基础知识的认知2024-10-19 18:18:00
  • java软件开发周期基础知识2024-10-19 18:18:00
  • Java基础 选择排序实例2024-10-19 18:18:00
  • 毕向东java基础35天目录2024-10-19 18:18:00
  • java基础语法在哪学2024-10-19 18:18:00
  • java基础21个变量2024-10-19 18:18:00
  • java基础中构造方法2024-10-19 18:18:00
  • java基础对象入门2024-10-19 18:18:00
  • java基础核心卷12024-10-19 18:18:00
  • java基础字符串教程2024-10-19 18:18:00