MySQL数据库 JDBC 编程(Java 连接 MySQL)

DataSource dataSource=new MysqlDataSource();
// DataSource 是来自于 Java 标准库的一个接口，它用来表示“数据库在哪”
// MysqlDataSource 是来自于 MySQL 的驱动包，它是实现了 DataSource 接口的类

// 1）通过一个 URL 来表示连接的数据库、数据库的 ip、端口、数据库名、编码方式、是否加密
((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&setSSL=false");
// 2）设置登录数据库的用户名
((MysqlDataSource)dataSource).setUser("root");
// 3）设置登录数据库的密码
((MysqlDataSource)dataSource).setPassword("1234");

Connection connection=dataSource.getConnection();

// 例如要执行新增元素操作（表名为 student，有两列 id 和 student
Scanner scanner=new Scanner(System.in);
System.out.print("请输入 id：");
int id=scanner.nextInt();
System.out.print("请输入 姓名：");
String name=scanner.next();
String sql="insert into student values(?,?)";

PreparedStatement statement=connection.prepareStatement(sql);
// 通过 setInt 方法，将 SQL 语句中的第一处通配符进行具体值的替换
statement.setInt(1,id);
// 通过 setString 方法，将 SQL 语句中的第二处通配符进行具体值的替换
statement.setString(2,name);

int ret=statement.executeUpdate();
// executeUpdate 的返回结果是执行该操作后影响的行数

// 可以通过打印返回值来显示影响的行数
System.out.println("ret: "+ret);

ResultSet resultSet=statement.executeQuery();
// executeQuery 的返回结果是执行该操作后查询到的类似于临时表的结构，存放在 ResultSet 对象中

// 接下来我们可以对它进行遍历，类似于迭代器的遍历，方法如下
while(resultSet.next()){
    // 假设有两列 id 和 name
    int id=resultSet.getInt(id);
    String name=resultSet.getString(name);
    System.out.println("id="+id+", name="+name);
}

// 如果有 ResultSet 对象不需要使用后，需要关闭这个连接
resultSet.close();

// Connection 不需要使用后，需要关闭这个连接
connection.close();

// PreparedStatement 不需要使用后，需要关闭这个连接
statement.close();

public static void test(){
    // 1. 创建数据库源，连接 Connection
 DataSource dataSource=new MysqlDataSource();
    ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");
    ((MysqlDataSource)dataSource).setUser("root");
    ((MysqlDataSource)dataSource).setPassword("1234");
    Connection connection=dataSource.getConnection();

    // 2. 构造一个 SQL 语句，为要进行的操作做准备
    String sql="";
    PreparedStatement statement=connection.prepareStatement(sql);

 // 3. 执行 SQL，并处理结果集
    int ret=statement.executeUpdate();

    // 4. 执行完成，释放资源
    statement.close();
    connection.close();
}

// 创建一个数据库源
DataSource dataSource=new MysqlDataSource();

// 设置数据库具体信息
((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("1234");

// 创建数据库连接
Connection connection=dataSource.getConnection();

// 加载 JDBC 驱动程序
Class.forName("com.mysql.cj.jdbc.Driver");

// 创建数据库连接
Connection connection=DriverManager.getConnection(url);

public static void testInsert() throws SQLException {
    DataSource dataSource=new MysqlDataSource();
    ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");
    ((MysqlDataSource)dataSource).setUser("root");
    ((MysqlDataSource)dataSource).setPassword("1234");
    Connection connection=dataSource.getConnection();
    Scanner scanner=new Scanner(System.in);
    System.out.print("请输入id：");
    int id=scanner.nextInt();
    System.out.print("请输入姓名：");
    String name=scanner.next();
    String sql="insert into student values(?,?)";
    PreparedStatement statement=connection.prepareStatement(sql);
    statement.setInt(1,id);
    statement.setString(2,name);
    int ret=statement.executeUpdate();
    System.out.println("ret: "+ret);
    statement.close();
    connection.close();
}

public static void testDelete() throws SQLException {
    DataSource dataSource=new MysqlDataSource();
    ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");
    ((MysqlDataSource)dataSource).setUser("root");
    ((MysqlDataSource)dataSource).setPassword("1234");
    Connection connection=dataSource.getConnection();
    Scanner scanner=new Scanner(System.in);
    System.out.print("请输入要删除的 id：");
    int id=scanner.nextInt();
    String sql="delete from student where id=?";
    PreparedStatement statement=connection.prepareStatement(sql);
    statement.setInt(1,id);
    int ret=statement.executeUpdate();
    System.out.println("ret: "+ret);
    statement.close();
    connection.close();
}

public static void testUpdate() throws SQLException {
    DataSource dataSource=new MysqlDataSource();
    ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");
    ((MysqlDataSource)dataSource).setUser("root");
    ((MysqlDataSource)dataSource).setPassword("1234");
    Connection connection=dataSource.getConnection();
    Scanner scanner=new Scanner(System.in);
    System.out.print("情输入你要更改的学生 id：");
    int id=scanner.nextInt();
    System.out.print("请输入你要更改后的学生姓名：");
    String name=scanner.next();
    String sql="update student set name=? where id=?";
    PreparedStatement statement=connection.prepareStatement(sql);
    statement.setString(1,name);
    statement.setInt(2,id);
    int ret=statement.executeUpdate();
    System.out.println("ret: "+ret);
    statement.close();
    connection.close();
}

public static void testSelect() throws SQLException {
    DataSource dataSource=new MysqlDataSource();
    ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");
    ((MysqlDataSource)dataSource).setUser("root");
    ((MysqlDataSource)dataSource).setPassword("1234");
    Connection connection=dataSource.getConnection();
    String sql="select * from student";
    PreparedStatement statement=connection.prepareStatement(sql);
    ResultSet resultSet=statement.executeQuery();
    while(resultSet.next()){
        int id=resultSet.getInt("id");
        String name=resultSet.getString("name");
        System.out.println("id = "+id+", name = "+name);
    }
    resultSet.close();
    statement.close();
    connection.close();
}