MySQL学习八JDBC

Posted 2021-08-26 毛_三月

目录

• JDBC
• • 第一个JDBC程序
  • statement对象
  • • tatement对象的三种常用方法
    • tatement对象的常用方法示例
    • tatement实战
    • 提取工具类
    • 测试exectueUpdate
    • • Insert增
      • Delete删
      • Update改
    • 测试executeQuery
    • • Select查
    • SQL注入问题
  • PreparedStatement
  • • Insert 增
    • Delete 删
    • Update改
    • Select查
  • 使用IDEA连接数据库
  • JDBC事务
  • • JDBC事务
    • 10.7.2 代码实现在这里插入图片描述
  • 数据库连接池
  • • DBCP代码实现
    • C3P0代码实现
    • 总结
• 更多相关文章点这里哦

JDBC

SUN 公司为了简化开发人员（对数据库的统一）的操作，提供了一个(Java操作数据库的)规范：JDBC

这些规范的实现由具体的厂商去做，比如mysql、oracle

对于开发人员来说，我们只需要掌握JDBC的接口操作即可

需要导入的包有

java.sql
javax.sql
数据库驱动包:mysql-connector-java

第一个JDBC程序

创建测试数据库

CREATE DATABASE jdbcStudy CHARACTER SET utf8 COLLATE utf8_general_ci;

USE jdbcStudy;

CREATE TABLE `users`(
id INT PRIMARY KEY,
NAME VARCHAR(40),
PASSWORD VARCHAR(40),
email VARCHAR(60),
birthday DATE
);

INSERT INTO `users`(id,NAME,PASSWORD,email,birthday)
VALUES(1,'zhansan','123456','[e-mail]','1980-12-04'),
(2,'lisi','123456','[e-mail]','1981-12-04'),
(3,'wangwu','123456','[e-mail]','1979-12-04')

• 编写Java代码

  • 1.创建一个普通项目
  • 2.导入数据库驱动

• 3.编写测试代码

package com.mao.lesson01;

import java.sql.*;

// 我的第一个JDBC程序
public class JdbcFirstDemo {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1.加载驱动
        Class.forName("com.mysql.jdbc.Driver");  //固定写法

        //2.用户信息和url
        String url ="jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&&useSSL=false";
        String username = "root";
        String password = "10428376";

        //3.连接成功，数据库对象  Connection 代表数据库
        Connection connection = DriverManager.getConnection(url, username, password);

        /*
            //connection代表数据库
            //数据库设置自动提交
            connection.setAutoCommit();
            //事务提交
            connection.commit();
            //事务回滚
            connection.rollback();
        */

        //4.执行SQL对象  Statement 执行sql的对象
        Statement statement = connection.createStatement();

        /*
        statement.executeQuery(); //查询操作返回 ResultSet
        statement.execute();      // 执行任何SQL
        statement.executeUpdate();//更新，插入，删除，返回一个受影响的行数
        */

        //5.执行SQL的对象 去 执行SQL，可能存在结果，查看返回结果
        String sql = "SELECT * FROM users";

        ResultSet resultSet = statement.executeQuery(sql);//返回的结果集，结果集中封装了我们全部查询出来的结果

        /*
        获得指定的数据类型
        *ResultSet resultSet = statement.executeQuery(sql);//返回的结果集,结果集中封装了我们全部查询的结果
        resultSet.getObject();//在不知道列类型下使用
        *
        resultSet.getString();//如果知道则指定使用
        resultSet.getInt();
        * */

        /*
        * 遍历,指针
        * resultSet.previous();//移动到前一行
        resultSet.next(); //移动到下一个
        resultSet.beforeFirst();//移动到最前面
        resultSet.afterLast();//移动到最后
        resultSet.absolute(row);//移动到指定行
        * */

        while (resultSet.next()){
            System.out.println("id:"+resultSet.getObject("id"));
            System.out.println("name:"+resultSet.getObject("NAME"));
            System.out.println("pwd:"+resultSet.getObject("PASSWORD"));
            System.out.println("emil:"+resultSet.getObject("email"));
            System.out.println("birth:"+resultSet.getObject("birthday"));
            System.out.println("==========================================");
        }
        //6.释放连接
        // 释放内存
        resultSet.close();
        statement.close();
        connection.close(); //耗资源
    }

}

步骤总结：

• 1.加载驱动
• 2.连接数据库 DriverManager
• 3.获取执行SQL的对象 Statement
• 4.获得返回的结果集
• 5.释放连接

分解：

1.驱动：DriverManager

Class.forName("com.mysql.jdbc.Driver");//固定写法
Connection connection= DriverManager.getConnection(url,name,password);

//connection代表数据库
//数据库设置自动提交
connection.setAutoCommit();
//事务提交
connection.commit();
//事务回滚
connection.rollback();

2.URL

String url ="jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&&useSSL=false";

3.获取执行SQL的对象 Statement

Statement statement = connection.createStatement();

4.执行SQL的对象

statement.executeQuery();
statement.execute();
statement.executeUpdate();//更新，插入，删除，返回一个受影响的行数

5.获得指定的数据类型

ResultSet resultSet = statement.executeQuery(sql);//返回的结果集,结果集中封装了我们全部查询的结果
resultSet.getObject();//在不知道列类型下使用
resultSet.getString();//如果知道则指定使用
resultSet.getInt();

6.遍历,指针

resultSet.previous();//移动到前一行
resultSet.next(); //移动到下一个
resultSet.beforeFirst();//移动到最前面
resultSet.afterLast();//移动到最后
resultSet.absolute(row);//移动到指定行

7.释放内存
resultSet.close();
statement.close();
connection.close();//耗资源

statement对象

Jdbc中的statement对象用于向数据库发送SQL语句，想完成对数据库的增删改查，只需要通过这个对象向数据库发送增删改查语句即可。

tatement对象的三种常用方法

• Statement对象的executeUpdate方法：用于向数据库发送增、删、改的sq|语句， executeUpdate执行完后，
  将会返回一个整数(即增删改语句导致了数据库几行数据发生了变化)。也可以用来做create和drop，不过比较少，create和drop常用excute（）方法。
• Statement.executeQuery多用来做select查询，executeQuery方法返回代表查询结果的ResultSet对象。
• Statement.execute：多用来做create和drop，也可以用来做insert、delete、update，不过比较少，insert、delete、update常用executeUpdate方法。

tatement对象的常用方法示例

使用executeUpdate(String sql)方法完成数据添加操作

 Statement statement = connection.createStatement();
        String sql = "insert into user(...) values(...)";
        int num = statement.executeUpdate(sql);
        if(num>0){
            System.out.println("插入成功");
        }

使用executeUpdate(String sql)方法完成数据删除操作

Statement statement = connection.createStatement();
        String sql = "delete from user where id =1";
        int num = statement.executeUpdate(sql);
        if(num>0){
            System.out.println("删除成功");
        }

使用executeUpdate(String sql)方法完成数据修改操作

Statement statement = connection.createStatement();
        String sql = "update user set name ='' where name = ''";
        int num = statement.executeUpdate(sql);
        if(num>0){
            System.out.println("修改成功");
        }

使用executeQuery(String sql)方法完成数据查询操作

Statement statement = connection.createStatement();
        String sql = "select * from  user where id =1";
        ResultSet rs= statement.executeQuery(sql);
        if(rs.next()){
            System.out.println("");

    }

tatement实战

提取工具类

编写配置文件

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&&useSSL=false
username = root
password = root

package com.mao.lesson02.utils;

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JdbcUtils {
    private  static String driver=null;
    private  static String url=null;
    private  static String username=null;
    private  static String password=null;

    static {

        try {
            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
            Properties properties =new Properties();
            properties.load(in);

            driver=properties.getProperty("driver");
            url=properties.getProperty("url");

            username=properties.getProperty("username");
            password=properties.getProperty("password");

            //1、驱动只用加载一次
            Class.forName(driver);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

        //获取连接
        public static Connection getConnection() throws SQLException {
            return DriverManager.getConnection(url, username, password);
        }

        //释放连接
        public static void release(Connection conn, Statement st, ResultSet rs){
            if (rs!=null){
                try {
                    rs.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (st!=null){
                try {
                    st.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (conn!=null){
                try {
                    conn.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }

        }

    public static void main(String[] args) {
        System.out.println(driver);
    }

}

测试exectueUpdate

Insert增

package com.mao.lesson02;

import com.mao.lesson02.utils.JdbcUtils;
//import jdk.nashorn.internal.ir.Statement;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestInsert {
    public static void main(String[] args) {
        Connection conn=null;
        Statement st= null;
        ResultSet rs =null;

        try {
            conn=JdbcUtils.getConnection();  //获取数据库连接
            st = conn.createStatement();   //获得SQL的执行对象
            String sql="INSERT INTO `users`(id,NAME,PASSWORD,email,birthday)" +
                    "VALUES(5,'sanmenxia','123456','[e-mail]','2000-02-01')";
            int i = st.executeUpdate(sql);
            if (i>0){
                System.out.println("插入成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

Delete删

package com.mao.lesson02;

import com.mao.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestDelete {
    public static void main(String[] args) {
        Connection conn=null;
        Statement st= null;
        ResultSet rs =null;

        try {
            conn= JdbcUtils.getConnection();  //获取数据库连接
            st = conn.createStatement();   //获得SQL的执行对象
            String sql="DELETE FROM users WHERE id = 5";
            int i = st.executeUpdate(sql);
            if (i>0){
                System.out.println("删除成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

Update改

package com.mao.lesson02;

import com.mao.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestUpdate {
    public static void main(String[] args) {
        Connection conn=null;
        Statement st= null;
        ResultSet rs =null;

        try {
            conn= JdbcUtils.getConnection();  //获取数据库连接
            st = conn.createStatement();   //获得SQL的执行对象
            String sql="UPDATE users SET `NAME`='huchao',`email`='[e-mail]' WHERE id=1;";
            int i = st.executeUpdate(sql);
            if (i>0){
                System.out.println("更新成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

测试executeQuery

Select查

package com.mao.lesson02;

import com.mao.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestSelect {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;

        try {
            conn = JdbcUtils.getConnection();//获取连接
            st = conn.createStatement();//获取SQL执行对象

            String sql = "select * from users";     //SQL
            rs=st.executeQuery(sql);//查询完毕返回结果集

            while (rs.next()){
                System.out.println(rs.getString("NAME"));
            }

        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,rs);
        }

    }
}

SQL注入问题

sql存在漏洞，会被攻击导致数据泄露，例如：如下代码可以在不知道用户名和密码的情况下绕过用户名和密码校验：

以上是关于MySQL学习八JDBC的主要内容，如果未能解决你的问题，请参考以下文章
 
 关于mysql驱动版本报错解决，Cause: com.mysql.jdbc.exceptions.jdbc4Unknown system variable ‘query_cache_size(代码片段
 mysql jdbc源码分析片段 和 Tomcat's JDBC Pool
 [八]数据库连接池与JDBC。纳尼？连接池关JDBC神马事？
 jdbc学习一半的代码
 如何在片段中填充列表视图？
 JDBC详解学习文档