准备工作
- idea
- mysql 官方的 jdbc 驱动
先在 idea 中建立一个新的 java 工程
直到这一步之前,一直按下一步就行了
把名字改改直接 finish
在这个工程下面建立一个名字为 lib 的空文件夹
去官方下载依赖的包
https://dev.mysql.com/downloads/connector/j/
选择下面那个
下载之后,得到的是一个 zip 文件,把 zip 里面的东西解压到刚刚创建的 lib 文件夹中(记得先找到刚刚那个工程创建时设置的存放位置)
右键这个文件夹,选择下面蓝色的那个选项
然后在弹出的窗口中点击 ok
后面还会弹出一个窗口,也点击 OK ,就可以了
开始操作
先在 src 文件夹中建立 Java 类,然后开始操作
连接 mysql 和关闭连接
Connection 是 Java 中的一个类,专门用于和其他的东西进行连接
// 先引入需要的包
import java.sql.*;
public class Exercise {
public static void main(String[] args){
// Connection 是 Java 中的一个类,专门用于和其他的东西进行连接
Connection connect = null;
try {
// 加载驱动,固定语句
// 使用这个必须处理异常
Class.forName("com.mysql.jdbc.Driver");
}
catch (ClassNotFoundException e){
System.out.println("Could not loading Driver");
}
try {
// 下面这一行也是固定语句,getConnection括号里面的模式:
// “jdbc:mysql://数据库的地址(mysql server 的地址)/数据库名字?(要mysql中操作的数据库的名字)”
// 后面再 + 上用来登录的用户名和密码
// 同时,使用这个函数,必须处理异常
connect = DriverManager.getConnection("jdbc:mysql://127.0.0.1/productdb?" + "user=root&password=123456");
if (connect != null) {
System.out.println("Connect successfully!");
}
} catch (SQLException e) { // 这个getConnection 规定必须抛出异常
e.printStackTrace();
}
finally {
try {
// 关闭连接
connect.close(); // 规定必须处理异常
System.out.println("Shutdown connection successfully!");
}
catch (SQLException e){
e.printStackTrace();
}
}
}
}
不要这么早就被这么长的代码给劝退了,实际上不需要写这么多,因为 idea 会帮你自动补全很大一部分,catch 里面的东西我几乎就没写过,而且 catch 里面的大多数都是英文的字面意思
使用 mysql 内的语句
使用 Statement 类的对象向 mysql 发送 sql 语句进行操作
使用 ResultSet 类的对象接收操作之后得到的结果
先上 mysql 的表
再进行操作
// 先引入需要的包
import java.sql.*;
public class Exercise {
public static void main(String[] args){
// Connection 是 Java 中的一个类,专门用于和其他的东西进行连接
Connection connect = null;
// Statement 类的对象向 mysql 发送 sql 语句进行操作
Statement stmt = null;
// ResultSet 类的对象接收操作之后得到的结果
ResultSet rs = null;
try {
// 加载驱动,固定语句
// 使用这个必须处理异常
Class.forName("com.mysql.jdbc.Driver");
}
catch (ClassNotFoundException e){
System.out.println("Could not loading Driver");
}
try {
// 下面这一行也是固定语句,getConnection括号里面的模式:
// “jdbc:mysql://数据库的地址(mysql server 的地址)/数据库名字?(要mysql中操作的数据库的名字)”
// 后面再 + 上用来登录的用户名和密码
// 同时,使用这个函数,必须处理异常
connect = DriverManager.getConnection("jdbc:mysql://127.0.0.1/productdb?" + "user=root&password=123456");
if (connect != null) {
System.out.println("Connect successfully!");
}
try {
// 先创造一个可以给 mysql 发送 sql 语句的
stmt = connect.createStatement();
// executeQuery 用于发送 sql 语句,括号内的就是 sql 语句
rs = stmt.executeQuery("select * from user");
// 输出数据的用法
//rs.next(); 表示下一个得到的结果数据集,如果不为空,就继续输出
// 每一次输出完之后,会自动切换到下一个数据集,相当于换行,select * from 表,这样操作一次看到结果
// 的图就知道是为什么了
while (rs.next()){
// rs.get数据类型(括号内是列数(第 n 列))
System.out.println(rs.getInt(1));
System.out.println(rs.getString(2));
System.out.println(rs.getString(3));
System.out.println(rs.getString(4));
System.out.println(rs.getString(5));
System.out.println(rs.getString(6));
System.out.println(rs.getTimestamp(7));
System.out.println(rs.getDate(8));
}
}
catch (SQLException e){ // 老规矩,必须处理异常
e.printStackTrace();
}
} catch (SQLException e) { // 这个getConnection 规定必须处理异常
e.printStackTrace();
}
finally {
try {
// 关闭连接
connect.close(); // 规定必须处理异常
System.out.println("Shutdown connection successfully!");
}
catch (SQLException e){
e.printStackTrace();
}
}
}
}