大数据必学Java基础(九十二):JDBC初识

举报
Lansonli 发表于 2022/12/15 15:42:54 2022/12/15
【摘要】 ​JDBC初识一、创建项目1、创建项目和模块.将jar文件放入项目的lib目录中2、给当前项目添加依赖(告诉当前项目/模块可以依赖jar文件中的代码)3、点击OK4、向部门表中添加一条数据package com.lanson.test1;import java.sql.Connection;import java.sql.Driver;import java.sql.DriverManage...

​JDBC初识

一、创建项目

1、创建项目和模块.将jar文件放入项目的lib目录中

2、给当前项目添加依赖(告诉当前项目/模块可以依赖jar文件中的代码)

3、点击OK

4、向部门表中添加一条数据

package com.lanson.test1;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.Statement;
/**
 * @Author: Lansonli
 * @Description: MircoMessage:Mark_7001
 */
public class TestJDBC {
    public static void main(String[] args) throws Exception {
        /*
        * 向Dept表增加一条数据
        *
        * */
        //1加载驱动 Driver
        Driver driver =new com.mysql.cj.jdbc.Driver();
        //2注册驱动 DriverManager
        DriverManager.registerDriver(driver);
        //3获得链接 Connection
        /*
        *
        * user:用户名
        * password:密码
        * url:统一资源定位符 定位我们要连接的数据库的
        *   1协议         jdbc:mysql
        *   2IP          127.0.0.1/localhost
        *   3端口号       3306
        *   4数据库名字   mydb
        *   5参数
        *   协议://ip:端口/资源路径?参数名=参数值&参数名=参数值&....
        *   jdbc:mysql://127.0.0.1:3306/mydb
        * */
        String url="jdbc:mysql://127.0.0.1:3306/mydb?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";
        String user="root";
        String password="root";
        Connection connection =DriverManager.getConnection(url, user,password );
        //4获得语句对象 Statment
        Statement statement = connection.createStatement();
        //5执行SQL语句,返回结果
        /*
        * insert delete update 操作都是调用statement.executeUpdate
        * executeUpdate返回一个int值,代表数据库多少行数据发生了变化
        * */
        String sql="insert into dept values(60,'教学部','深圳');";
        int rows = statement.executeUpdate(sql);
        System.out.println("影响数据行数为:"+rows);
        //6释放资源
        /*
        * 注意顺序
        * 后获得的先关闭,先获得的后关闭
        * */
        statement.close();
        connection.close();
    }
}


二、错误原因总结

MySQL8中数据库连接的四个参数有两个发生了变化

String driver = "com.mysql.cj.jdbc.Driver";

String url = "jdbc:mysql://127.0.0.1:3306/mydb?useSSL=false&useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai";

或者String url = ".......serverTimezone=GMT%2B8";

错误1:Exception in thread "main" java.lang.ClassNotFoundException: com.mysql.jdbc2.Driver

原因:没有添加jar包或者com.mysql.jdbc2.Driver路径错误

错误2:Exception in thread "main" java.sql.SQLException:No suitable driver found for jbdc:mysql://127.0.0.1:3306/stumgr

原因:url错误

错误3:Exception in thread "main" java.sql.SQLException:Access denied for user 'root'@'localhost' (using password: YES)

原因:用户名或者密码错误

错误4:Exception in thread "main" com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException:Duplicate entry '90' for key 'PRIMARY'

原因:主键冲突

错误5:Public Key Retrieval is not allowed

如果用户使用 sha256_password 认证,密码在传输过程中必须使用 TLS 协议保护,但是如果 RSA 公钥不可用,可以使用服务器提供的公钥;可以在连接中通过 ServerRSAPublicKeyFile 指定服务器的 RSA 公钥,或者AllowPublicKeyRetrieval=True参数以允许客户端从服务器获取公钥;但是需要注意的是 AllowPublicKeyRetrieval=True可能会导致恶意的代理通过中间人攻击(MITM)获取到明文密码,所以默认是关闭的,必须显式开启

在jdbc连接添加上参数allowPublicKeyRetrieval=true即可,注意参数间用&

三、驱动的加载

加载数据库驱动时,我们可以通过自己创建一个实例的方式,然后去注册驱动

在查看Driver的源代码时我们发现,该类内部有一个静态代码块,在代码块中就是在实例化一个驱动并在驱动中心注册.静态代码块会在类进入内存时执行,也就是说,我们只要让该类字节码进入内存,就会自动完成注册,不需要我们手动去new。

所以我们在代码中直接使用反射,通过Class.forName("com.mysql.jdbc.Driver"),加载该类进入内存即可。

我们继续查看jar包发现,jar包中已经默认配置了驱动类的加载

jar--META-INF--services--java.sql.Driver--com.mysql.jdbc.Driver,在加载jar包时,会自动读取该内容并加载驱动,所以我们不去编写Class.forName("com.mysql.jdbc.Driver"),程序也是可以自动完成加载驱动的。

四、结合异常处理代码

package com.lanson.test1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
/**
 * @Author: Lansonli
 * @Description: MircoMessage:Mark_7001
 */
public class TestJDBC3 {
    private static String driver ="com.mysql.cj.jdbc.Driver";
    private static String url="jdbc:mysql://127.0.0.1:3306/mydb?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true";
    private static String user="root";
    private static String password="root";
    public static void main(String[] args)  {
        Connection connection=null;
        Statement statement=null;
        try{
            Class.forName(driver);
            connection =DriverManager.getConnection(url, user,password);
            statement = connection.createStatement();
            String sql="insert into dept values(DEFAULT ,'助教部门','北京');";
            int rows = statement.executeUpdate(sql);
            System.out.println("影响数据行数为:"+rows);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if(null != statement){
                try {
                    statement.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(null != connection){
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。