mysql 驱动包 mysql-connect-java_mysql-connector-java

mysql的驱动包 mysql-connect-java

1. 内部封装了jdbc:

• jdbc(java database connectivity):本身是由一组接口组成 , 可以使得Java编译来访问各种数据库
• 无需自己实现接口,这些接口的实现类由第三方数据库厂商实现

jdbc的核心

2. jdbc四个参数
   • 用户名
   • 密码
   • 驱动类的全名 : com.mysql.jdbc.Driver
   • 连接字符串的url : mysql8.0以前 jdbc:mysql://真实ip:3306/database_name mysql8.0以后:jdbc:mysql://真实ip:3306/database_name?serverTimezone=UTC&characterEncoding=utf8&useUnicode=true&useSSL=true

DriverManager 类 ,Connection接口 ,Statement接口

DriverManager类

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
/**
运行这一段要求:
1.导入对应数据库版本的mysql-connector-java 包
2.url要对应数据库版本的书写
**/
public class Demo01Jdbc {
    public static void main(String[] args) throws SQLException {
    //mysql8.0以后使用的url
        String url = "jdbc:mysql://localhost:3306/database_name?serverTimezone=UTC&characterEncoding=utf8&useUnicode=true&useSSL=true";
        Connection connection = DriverManager.getConnection(url, "root", "root");
        System.out.println(connection);

//DriverManager内部静态方法
//  public static Connection getConnection(String url, java.util.Properties info)
//  public static Connection getConnection(String url,String user, String password)
//  public static Connection getConnection(String url)
//properties方式连接
//之所以可以使用properties是因为在DriverManager.getConnection()中也是创建properties对象
//只这里的properties对象通过setProperties()重新设置的键值对元素
//而getConnection()中设置好了键元素,只要求用户传入值即可

        Properties properties = new Properties();
        properties.setProperty("user","root");
        properties.setProperty("password","root");

        Connection connection1 = DriverManager.getConnection(url, properties);
        System.out.println(connection1);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

• 为了切合java思想可以将封装为:

import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.SQLException;

public class JDBCLink {
//连接本地jdbc:mysql://localhost:3306/database_name?...    可以省略为jdbc:mysql:///database_name?...
    private static final String url = "jdbc:mysql:///database_name?serverTimezone=UTC&characterEncoding=utf8&useUnicode=true&useSSL=true";
    private static final String user = "root";
    private static final String password = "root";
    public static Connection connection;

    public static Connection getConnection() {
        return connection;
    }
    /**
    开始连接
    **/
    public static void startLink(){
        try {
            connection = DriverManager.getConnection(url, user, password);
            System.out.println(connection);
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
    
    /**
    结束释放资源
    **/
    public static void end(){
        try {
            connection.close();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

---

Statement接口

创建表格:

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

public class Demo2DDL {
    public static void main(String[] args) throws SQLException {
        String sql = "create table stu(id int primary key auto_increment,name varchar(20) not null,sex boolean,birthday date)";

        JDBCLink.startLink();
        Connection connection = JDBCLink.getConnection();
        Statement statement = connection.createStatement();
        statement.execute(sql);
        statement.close();
        JDBCLink.end();
        System.out.println("创建表成功");
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

插入数据:

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

public class Demo02Insert {
    public static void main(String[] args) throws SQLException {

        JDBCLink.startLink();
        Connection connection = JDBCLink.getConnection();
        Statement statement = connection.createStatement();
        //更新和删除同样在这里操作
        int row = statement.executeUpdate("insert into stu (name,sex,birthday) values ('张三',1,'1999-2-10')," +
                "('李四',1,'1999-2-10'),('王五',1,'1999-2-10'),('赵六',1,'1999-2-10')");
        System.out.println(row);
        statement.close();
        JDBCLink.end();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

对应stu表的实体类:

import java.util.Date;
public class Stu {
    private int id;
    private String name;
    private boolean sex;
    private Date birthday;

    public Stu() {
    }

    public Stu(int id, String name, boolean sex, Date birthday) {
        this.id = id;
        this.name = name;
        this.sex = sex;
        this.birthday = birthday;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public boolean isSex() {
        return sex;
    }

    public void setSex(boolean sex) {
        this.sex = sex;
    }

    public Date getBirthday() {
        return birthday;
    }

    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }

    @Override
    public String toString() {
        return "Stu{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", sex=" + sex +
                ", birthday=" + birthday +
                '}';
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

查询:

import com.pojo.Stu;

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

public class Demo03Select {
    public static void main(String[] args) throws SQLException {

        JDBCLink.startLink();
        Connection connection = JDBCLink.getConnection();

        Statement statement = connection.createStatement();
        ResultSet resultSet = statement.executeQuery("select * from stu");

        LinkedList<Stu> stus = new LinkedList<>();
        Stu stu = new Stu();
        while (resultSet.next()){
            stu.setId(resultSet.getInt("id"));
            stu.setName(resultSet.getString("name"));
            stu.setSex(resultSet.getBoolean("sex"));
            stu.setBirthday(resultSet.getDate("birthday"));
            stus.add(stu);
        }

        for (Stu stus1 : stus) {
            System.out.println(stus1);
        }

        statement.close();
        JDBCLink.end();
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37