【2019.10.08】Java JDBC 基本操作

曾经终败给现在 2023-06-04 11:50 16阅读 0赞

Mysql 基本介绍

SQL

1.      什么是SQL？
    
    1.  Structured Query Language：结构化查询语言

1.      SQL 通用语法
    
    1.  SQL语句可以单行或者多行书写，以“；”结束
    2.  空格 tab
    3.  不区分大小写，关键字建议大写。
    4.  3中注释
        
        \* 单行注释： -- 注释内容              或者 \# 注释内容
        
        \* 多行注释： /\* 注释内容 \*/

DDL：操作数据库，表

1、操作数据库：CRUD

1.  C(Create）创建
    
    1.  创建db4数据库，判断是否存在，并指定字符集为gbk
        
        create database if not exists db4 character gbk;
2.  R(Retrieve): 查询
    
    1.  查询所有数据库的名称
        
        show databases;
    2.  查询某个数据库的字符集：查询某个数据库的创建语句
        
        show create database mysql
3.  U（Updata）：修改
    
    1.  修改数据库的字符集
        
        alter database 数据库名称 character ser 字符集名称；
4.  D（Delete）：删除
    
    1.  删除 数据库
        
        drop database 数据库名称；
    2.  判断数据库是否存在，再删除
        
        drop database if exists 数据库名称；
5.  使用数据库
    
    1.  查询正在数据的数据库
        
        select database();
    2.  使用数据库
        
        use 数据库名称；

--------------------

JDBC

*  概念： Java Database Connectivity Java数据库连接，Java语言操作数据库

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4NTM0MTA3_size_16_color_FFFFFF_t_70][]

数据库驱动

*  JDBC本质：官方（SUN公司）定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动的jar包。我们可以使用这套接口（JDBC）编程，真正执行的代码是Jar包中的实现类。
 *  快速入门
    
     *  步骤：
        
         *  导入驱动
         *  注册驱动
         *  获取数据库连接对象 Connection
         *  定义sql
         *  获取执行sql语句的对象 Statement
         *  执行sql，接受返回结果
         *  处理结果
         *  释放资源
 *  代码

import java.sql.Connection;
    
    import java.sql.DriverManager;
    
    import java.sql.Statement;
    
    
    
    
    
    public class JdbcDemo1 {
    
        public static void main(String[] args) throws Exception {
    
            // *导入驱动
    
            // *注册驱动
    
            Class.forName("com.mysql.cj.jdbc.Driver");
    
            // *获取数据库连接对象 Connection
    
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3?serverTimezone=UTC", "root", "root");
    
            // *定义sql
    
            String sql = "insert into account(name, balance) values('Paulson1', 2000)";
    
            // *获取执行sql语句的对象 Statement
    
            Statement statement = conn.createStatement();
    
            // *执行sql，接受返回结果
    
            boolean execute = statement.execute(sql);
    
            // *处理结果
    
            System.out.println(execute);
    
            // *释放资源
    
            statement.close();
    
            conn.close();
    
        }
    
    }

3、 详解各个对象

1.  DriverManager：驱动管理对象
    
    \- 功能：
    
    1.  注册驱动
        
        通过查询源码发现，在 com.mysql.cj.jdbc.Driver 中 存在如下静态块

static {
    
        try {
    
            DriverManager.registerDriver(new Driver());
    
        } catch (SQLException var1) {
    
            throw new RuntimeException("Can't register driver!");
    
        }
    
    }

// 注意：mysql 5 之后的驱动jar包中可以省略注册驱动的步骤。

1.  获取数据库连接
2.  Connection：数据库连接对象
    
    1.  功能
        
        1.  获取执行sql的对象
        2.  管理事务
            
            1.  开启事务 setAutocommit()
            2.  提交事务 commit()
            3.  回滚事务 roolback()
3.  Statement：执行sql对象
    
    1.  excute
    2.  excuteUpdate(String sql) : 执行DML语句（insert、updata、delete），DDL语句（create， alter， drop）
        
        返回值：是影响的行数，可以通过这个影响的行数判断DML语句是否执行成功，返回值 > 0 表明执行成功
    3.  ResultSet executeQuery（）：执行DQL语句（select）语语句
4.  ResultSet：结果集对象，封装查询的结果
    
    1.  next 游标向下移动一行
    2.  getXXX() 获取数据
        
        XXX ：代表数据类型       如：getInt（）  
          
        注意：
        
        1.  使用步骤：
            
            1.  游标向下移动一行
            2.  判断是否有数据 Boolean  next 如果不是最后一行，返回true
            3.  获取数据
5.  PreparedStatement：执行SQL的对象

/*
    
    建表
    
    */
    
    create table account(     
    
        id int unsigned auto_increment primary key not null,
    
        name varchar(30) not null,
    
        balance int unsigned default 0
    
    );

/*
    
    添加记录
    
    */
    
    public class JdbcDemo2 {
    
        public static void main(String[] args) {
    
            Statement statement = null;
    
            Connection conn = null;
    
            // *导入驱动
    
            // *注册驱动
    
            try {
    
                Class.forName("com.mysql.cj.jdbc.Driver");
    
    
    
    
    
            // *获取数据库连接对象 Connection
    
            conn = DriverManager.getConnection("jdbc:mysql:///db3?serverTimezone=UTC", "root", "mima");
    
            // *定义sql
    
            String sql = "insert into account(name, balance) values('myy', 3500)";
    
            // *获取执行sql语句的对象 Statement
    
            statement = conn.createStatement();
    
            int count = statement.executeUpdate(sql);
    
    
    
    
    
            if(count > 0 )
    
                System.out.println("添加成功！");
    
            else
    
                System.out.println("添加失败");
    
            } catch (ClassNotFoundException e) {
    
                e.printStackTrace();
    
            } catch (SQLException e) {
    
                e.printStackTrace();
    
            }finally {
    
                // *释放资源
    
                if(statement != null){
    
                    try {
    
                        statement.close();
    
                    } catch (SQLException e) {
    
                        e.printStackTrace();
    
                    }
    
                }
    
                if (conn != null){
    
                    try {
    
                        conn.close();
    
                    } catch (SQLException e) {
    
                        e.printStackTrace();
    
                    }
    
                }
    
            }
    
    
    
    
    
        }
    
    }

/*
    
    更新记录
    
    */
    
    public class JdbcDemo1 {
    
        public static void main(String[] args) throws Exception {
    
            // *导入驱动
    
            // *注册驱动
    
            Class.forName("com.mysql.cj.jdbc.Driver");
    
            // *获取数据库连接对象 Connection
    
    //        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3?serverTimezone=UTC", "root", "mima");
    
            Connection conn = DriverManager.getConnection("jdbc:mysql:///db3?serverTimezone=UTC", "root", "mima");
    
            // *定义sql
    
    //        String sql = "insert into account(name, balance) values('Paulson1', 2000)";
    
            String sql = "update account set balance=1500 where id=3";
    
            // *获取执行sql语句的对象 Statement
    
            Statement statement = conn.createStatement();
    
            // *执行sql，接受返回结果
    
    //        boolean execute = statement.execute(sql);
    
            int i = statement.executeUpdate(sql);
    
            // *处理结果
    
            System.out.println(i);
    
            // *释放资源
    
            statement.close();
    
            conn.close();
    
        }
    
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4NTM0MTA3_size_16_color_FFFFFF_t_70]: /images/20230601/22691b495719456e8f5c6418d42f7372.png