IDEA用Maven连接MySQL的jdbc驱动，并操作数据库

时间：2019-11-26 23:08:15 阅读：491 评论：0 收藏：0 [点我收藏+]

标签：mysql etc resources load return use cti url round

1、在IDEA里创建Maven项目

点击Create New Project

选择Maven，JDK这里用的是1.8，点击Next

填入“组织名”、“项目名”，版本是默认的，点击Next

选择创建路径，点击Finsh

这是创建完成的界面

2、用Maven连接Mysql的JDBC驱动

打开src下的pom.xml文件，在里面添加Mysql的jdbc包的引用，如下图红框中的内容
代码

<dependencies>
   <dependency>
       <groupId>mysql</groupId>
       <artifactId>mysql-connector-java</artifactId>
       <version>8.0.18</version>
   </dependency>
</dependencies>
　　　　

添加完成后，IDEA右下角会出现下图提示，点击提示中的Import Changes，Maven就会开始下载资源

下载时页面左下角出现正在下载的提示

下载完成变成绿勾

3、连接数据库第一种方式：注册驱动，向数据库插入数据（不推荐使用）

在src——main——java目录下，新建一个LinkDatabaseInsert的类

代码

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

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

运行程序，返回1，说明插入成功

4、连接数据库第二种方式——新建数据库配置文件，向数据库插入数据（推荐使用）

4.1、利用反射获取db.properties文件信息

在src——main——resources目录下，新建db.properties文件

代码

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://rm-uf6lg6rxego.mysql.rds.aliyuncs.com:3306/study
user=root
password=wY123!
　　　　

新建util包，然后在里面创建JdbcUtil类，利用反射获取db.properties文件信息，最后返回数据库连接

代码

package util;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;

//获取到db.properties文件中的数据库信息
public class JdbcUtil {
   //私有变量
   private static String driver;
   private static String url;
   private static String user;
   private static String password;

   //静态块
   static{
       try{
           //1.新建属性集对象
           Properties properties = new Properties();
           //2通过反射，新建字符输入流，读取db.properties文件
           InputStream input = JdbcUtil.class.getClassLoader().getResourceAsStream("db.properties");
           //3.将输入流中读取到的属性，加载到properties属性集对象中
           properties.load(input);
           //4.根据键，获取properties中对应的值
           driver = properties.getProperty("driver");
           url = properties.getProperty("url");
           user = properties.getProperty("user");
           password = properties.getProperty("password");
       }catch(Exception e){
           e.printStackTrace();
       }
   }

   //返回数据库连接
   public static Connection getConnection(){
       try{
           //注册数据库的驱动
           Class.forName(driver);
           //获取数据库连接（里面内容依次是：主机名和端口、用户名、密码）
           Connection connection = DriverManager.getConnection(url,user,password);
           //返回数据库连接
           return connection;
       }catch (Exception e){
           e.printStackTrace();
       }
       return null;
   }
}
　　　　

在java目录下创建LinkMysql类，调用JdbcUtil类返回的数据库连接操作数据库

代码

import util.JdbcUtil;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

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

运行程序，返回1，说明插入成功

4.2、通过ResourceBundle类获取db.properties文件信息

在util包里面创建创建JdbcUtil2类，ResourceBundle类获取db.properties文件信息，最后返回数据库连接

代码

package util;

import java.sql.*;
import java.util.ResourceBundle;

public class JdbcUtil2 {
   //私有变量
   private static String driver;
   private static String url;
   private static String user;
   private static String password;

   //静态块
   static{
       try{
           //2.3通过ResourceBundle类拿到数据库连接信息
           ResourceBundle resourceBundle = ResourceBundle.getBundle("db");
           driver = resourceBundle.getString("driver");
           url = resourceBundle.getString("url");
           user = resourceBundle.getString("user");
           password = resourceBundle.getString("password");
       }catch(Exception e){
           e.printStackTrace();
       }
   }

   //返回数据库连接
   public static Connection getConnection(){
       try{
           //注册数据库的驱动
           Class.forName(driver);
           //获取数据库连接（里面内容依次是：主机名和端口、用户名、密码）
           Connection connection = DriverManager.getConnection(url,user,password);
           //返回数据库连接
           return connection;
       }catch (Exception e){
           e.printStackTrace();
       }
       return null;
   }

   //关闭结果集
   public static void closeResultSet(ResultSet resultSet) {
       if (resultSet != null) {
           try {
               resultSet.close();
           } catch (SQLException e) {
               e.printStackTrace();
           }
       }
   }

   //关闭预处理对象
   public static void closeStatement(Statement statement) {
       if (statement != null) {
           try {
               statement.close();
           } catch (SQLException e) {
               e.printStackTrace();
           }
       }
   }

   //关闭数据库连接
   public static void closeConnection(Connection connection){
       if(connection != null){
           try {
               connection.close();
           } catch (SQLException e) {
               e.printStackTrace();
           }
       }
   }

   //一次性关闭上面三个
   public static void closeResource(ResultSet resultSet,Statement statement,Connection connection){
       closeResultSet(resultSet);
       closeStatement(statement);
       closeConnection(connection);
   }
}

在java目录下创建LinkMysql2类，调用JdbcUtil2类返回的数据库连接操作数据库

代码

import util.JdbcUtil2;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class LinkMysql2 {
   public static void main(String[] args) throws ClassNotFoundException, SQLException {
       //获取数据库连接
       Connection connection = JdbcUtil2.getConnection();
       //需要执行的sql语句
       String sql = "insert into stu(id,name,age) values(?,?,?)";
       //获取预处理对象，并给参数赋值
       PreparedStatement statement = connection.prepareCall(sql);
       statement.setInt(1,19);
       statement.setString(2,"王五");
       statement.setInt(3,16);
       //执行sql语句（执行了几条记录，就返回几）
       int i = statement.executeUpdate();  //executeUpdate：执行并更新
       System.out.println(i);
       //关闭jdbc连接
       JdbcUtil2.closeResource(null,statement,connection);
   }
}

运行程序，返回1，说明插入成功

IDEA用Maven连接MySQL的jdbc驱动，并操作数据库

标签：mysql etc resources load return use cti url round

原文地址：https://www.cnblogs.com/dadian/p/11938707.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行