IDEA 通过 Maven 连接到 MySQL 的 jdbc 驱动程序并操作数据库

1 <dependencies>
2     <dependency>
3         <groupId>mysql</groupId>
4         <artifactId>mysql-connector-java</artifactId>
5         <version>8.0.18</version>
6     </dependency>
7 </dependencies>

 1 import java.sql.Connection;
 2 import java.sql.DriverManager;
 3 import java.sql.PreparedStatement;
 4 import java.sql.SQLException;
 5 
 6 public class LinkDatabaseInsert {
 7     public static void main(String[] args) throws ClassNotFoundException, SQLException {
 8         //1.注册数据库的驱动
 9         Class.forName("com.mysql.jdbc.Driver");
10         //2.获取数据库连接（里面内容依次是："jdbc:mysql://主机名:端口号/数据库名","用户名","登录密码"）
11         Connection connection = DriverManager.getConnection("jdbc:mysql://rm-uf6lgkv4fd9776rxego.mysql.rds.aliyuncs.com:3306/study","root","whmilyY123!");
12         //3.需要执行的sql语句（?是占位符，代表一个参数）
13         String sql = "insert into stu(id,name,age) values(?,?,?)";
14         //4.获取预处理对象，并依次给参数赋值
15         PreparedStatement statement = connection.prepareCall(sql);
16         statement.setInt(1,12); //数据库字段类型是int，就是setInt；1代表第一个参数
17         statement.setString(2,"小明");    //数据库字段类型是String，就是setString；2代表第二个参数
18         statement.setInt(3,16); //数据库字段类型是int，就是setInt；3代表第三个参数
19         //5.执行sql语句（执行了几条记录，就返回几）
20         int i = statement.executeUpdate();
21         System.out.println(i);
22         //6.关闭jdbc连接
23         statement.close();
24         connection.close();
25     }
26 }

 1 package util;
 2 
 3 import java.io.InputStream;
 4 import java.sql.Connection;
 5 import java.sql.DriverManager;
 6 import java.util.Properties;
 7 
 8 //获取到db.properties文件中的数据库信息
 9 public class JdbcUtil {
10     //私有变量
11     private static String driver;
12     private static String url;
13     private static String user;
14     private static String password;
15 
16     //静态块
17     static{
18         try{
19             //1.新建属性集对象
20             Properties properties = new Properties();
21             //2通过反射，新建字符输入流，读取db.properties文件
22             InputStream input = JdbcUtil.class.getClassLoader().getResourceAsStream("db.properties");
23             //3.将输入流中读取到的属性，加载到properties属性集对象中
24             properties.load(input);
25             //4.根据键，获取properties中对应的值
26             driver = properties.getProperty("driver");
27             url = properties.getProperty("url");
28             user = properties.getProperty("user");
29             password = properties.getProperty("password");
30         }catch(Exception e){
31             e.printStackTrace();
32         }
33     }
34 
35     //返回数据库连接
36     public static Connection getConnection(){
37         try{
38             //注册数据库的驱动
39             Class.forName(driver);
40             //获取数据库连接（里面内容依次是：主机名和端口、用户名、密码）
41             Connection connection = DriverManager.getConnection(url,user,password);
42             //返回数据库连接
43             return connection;
44         }catch (Exception e){
45             e.printStackTrace();
46         }
47         return null;
48     }
49 }

 1 import util.JdbcUtil;
 2 
 3 import java.sql.Connection;
 4 import java.sql.PreparedStatement;
 5 import java.sql.SQLException;
 6 
 7 public class LinkMysql {
 8     public static void main(String[] args) throws ClassNotFoundException, SQLException {
 9         //获取数据库连接
10         Connection connection = JdbcUtil.getConnection();
11         //需要执行的sql语句
12         String sql = "insert into stu(id,name,age) values(?,?,?)";
13         //获取预处理对象，并给参数赋值
14         PreparedStatement statement = connection.prepareCall(sql);
15         statement.setInt(1,14);
16         statement.setString(2,"李四");
17         statement.setInt(3,16);
18         //执行sql语句（插入了几条记录，就返回几）
19         int i = statement.executeUpdate();  //executeUpdate：执行并更新
20         System.out.println(i);
21         //关闭jdbc连接
22         statement.close();
23         connection.close();
24     }
25 }

 1 import util.JdbcUtil2;
 2 
 3 import java.sql.Connection;
 4 import java.sql.PreparedStatement;
 5 import java.sql.SQLException;
 6 
 7 public class LinkMysql2 {
 8     public static void main(String[] args) throws ClassNotFoundException, SQLException {
 9         //获取数据库连接
10         Connection connection = JdbcUtil2.getConnection();
11         //需要执行的sql语句
12         String sql = "insert into stu(id,name,age) values(?,?,?)";
13         //获取预处理对象，并给参数赋值
14         PreparedStatement statement = connection.prepareCall(sql);
15         statement.setInt(1,19);
16         statement.setString(2,"王五");
17         statement.setInt(3,16);
18         //执行sql语句（执行了几条记录，就返回几）
19         int i = statement.executeUpdate();  //executeUpdate：执行并更新
20         System.out.println(i);
21         //关闭jdbc连接
22         JdbcUtil2.closeResource(null,statement,connection);
23     }
24 }
25 import util.JdbcUtil2;
26 
27 import java.sql.Connection;
28 import java.sql.PreparedStatement;
29 import java.sql.SQLException;
30 
31 public class LinkMysql2 {
32     public static void main(String[] args) throws ClassNotFoundException, SQLException {
33         //获取数据库连接
34         Connection connection = JdbcUtil2.getConnection();
35         //需要执行的sql语句
36         String sql = "insert into stu(id,name,age) values(?,?,?)";
37         //获取预处理对象，并给参数赋值
38         PreparedStatement statement = connection.prepareCall(sql);
39         statement.setInt(1,19);
40         statement.setString(2,"王五");
41         statement.setInt(3,16);
42         //执行sql语句（执行了几条记录，就返回几）
43         int i = statement.executeUpdate();  //executeUpdate：执行并更新
44         System.out.println(i);
45         //关闭jdbc连接
46         JdbcUtil2.closeResource(null,statement,connection);
47     }
48 }