JDBC连接并操作Mysql数据库

刺骨的言语ヽ痛彻心扉 2022-02-18 12:51 343阅读 0赞

使用Java连接数据库需要使用JDBC驱动。JDBC（Java Data Base Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。以下是使用方法

### 1、注册驱动 ###

*  Class.forName(“com.mysql.jdbc.Driver”); 或者
 *  DriverManager.registerDriver(new com.mysql.jdbc.Driver());

### 2、获取连接 ###

*  Connection conn = (Connection) DriverManager.getConnection(URL,USER,PASS);
 *  URL为数据库地址（含端口号），后两个参数为数据库用户名和密码

### 3、获取statement ###

*  Statement stat = conn.createStatement();
 *  或PreparedStatement preStat = conn.prepareStatement(sql)。PreparedStatement继承自Statement，比Statement的效率更高，并且可以防止SQL注入，使用较多; PreparedStatement()传入的参数sql含有未知量，须进一步设置。

### 4、 执行SQL并返回结果 ###

*  执行select使用executeQuery()，返回ResultSet类型；
 *  执行insert、update、delete等使用executeUpdate()，返回影响的行数（int类型）；

import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import com.mysql.jdbc.Connection;
    
    public class Test {
        static final String DB_URL = "jdbc:mysql://localhost:3306/databaseweb";
        // MySQL的JDBC URL编写方式：jdbc:mysql://主机名称：连接端口/数据库的名称
        static final String USER = "root";
        static final String PASS = "123";
    
        public static void main(String[] args) throws SQLException,Exception{
           Connection conn = null;
           Statement stat = null;
    
           // 注册驱动
           Class.forName("com.mysql.jdbc.Driver");
    
           // 创建链接
           conn = (Connection) DriverManager.getConnection(DB_URL,USER,PASS);
    
           // 执行查询
           stat = conn.createStatement();
           String sql = "SELECT * FROM tb_person";
           ResultSet rs = stat.executeQuery(sql);
           // 输出查询结果
           while(rs.next()){
               System.out.print(rs.getInt("id")+",");
               System.out.print(rs.getString("name")+",");
               System.out.print(rs.getString("sex")+",");
               System.out.print(rs.getInt("age"));
               System.out.print("\n");
           }
           // 关闭
          try {
              if (rs != null) {
                  rs.close();
              }
          } catch (SQLException e) {
              e.printStackTrace();
          } finally {
              try {
                  if (stat != null) {
                      stat.close();
                  }
              } catch (SQLException e) {
                  e.printStackTrace();
              } finally {
                  try {
                      if (conn != null) {
                          conn.close();
                      }
                  } catch (SQLException e) {
                      e.printStackTrace();
                  }
              }
          }
        }
    }