Java를 사용하여 MySQL을 쿼리, 수정 및 연결하는 방법에 대한 자세한 설명

이 글에서는 주로 Java에서 MySQL 데이터베이스를 연결하고 쿼리하고 수정하는 방법을 소개합니다. 필요하신 분들은 참고하시면 됩니다

0. 일반 프로세스:

　　(1) Class.forName() 메서드를 호출합니다. 드라이버를 로드합니다.

　(2) DriverManager 객체의 getConnection() 메서드를 호출하여 Connection 객체를 얻습니다.

　　(3) Statement 객체를 생성하고 SQL 문을 준비합니다. 이 SQL 문은Statement 객체(즉시 실행될 명령문), preparedStatement 명령문(미리 컴파일된 명령문) 또는 CallableStatement 객체(호출할 명령문)일 수 있습니다. 저장 프로시저를 통해).

　　(4) excuteQuery()와 같은 메서드를 호출하여 SQL 문을 실행하고 결과를 ResultSet 개체에 저장하거나, ExecuteUpdate()와 같은 메서드를 호출하여 ResultSet 개체의 결과를 반환하지 않고 SQL 문을 실행합니다.

　 (5) 반환된 ResultSet 객체에 대해 표시 및 기타 동등한 처리를 수행합니다.

　 (6) 리소스를 공개합니다.

1. 데이터베이스에 연결합니다

　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　 데이터베이스를 통해

　　(2) JDBC 드라이버 로드

작업 방법: Eclipse에서 해당 프로젝트를 선택하고 Project-Properties에서 Java Build Path를 클릭한 후 Libraries에 mysql-connector-java-5.1.21-bin.jar을 추가합니다. 좋아요.

　　(3) 다음과 같이 간단한 데이터베이스를 구축합니다.

import java.sql.*;
public class GetConnection {
  public static void main(String[] args){
    try{
      //调用Class.forName()方法加载驱动程序
      Class.forName("com.mysql.jdbc.Driver");
      System.out.println("成功加载MySQL驱动！");
    }catch(ClassNotFoundException e1){
      System.out.println("找不到MySQL驱动!");
      e1.printStackTrace();
    }
    String url="jdbc:mysql://localhost:3306/mysql";  //JDBC的URL
    //调用DriverManager对象的getConnection()方法，获得一个Connection对象
    Connection conn;
    try {
      conn = DriverManager.getConnection(url,  "root","");
      //创建一个Statement对象
      Statement stmt = conn.createStatement(); //创建Statement对象
      System.out.print("成功连接到数据库！");
      stmt.close();
      conn.close();
    } catch (SQLException e){
      e.printStackTrace();
    }
  }
}

2. 데이터 테이블을 쿼리합니다　데이터 테이블을 쿼리할 때는 데이터와 유사한 ResultSet 인터페이스를 사용해야 합니다. 이 인터페이스 인스턴스를 통해 검색 결과 집합과 해당 데이터 테이블의 인터페이스 정보를 얻을 수 있습니다.

import java.sql.*;
public class SelectTable {
  public static void main(String[] args){
    try{
      //调用Class.forName()方法加载驱动程序
      Class.forName("com.mysql.jdbc.Driver");
      System.out.println("成功加载MySQL驱动！");
      String url="jdbc:mysql://localhost:3306/aniu";  //JDBC的URL
      Connection conn;
      conn = DriverManager.getConnection(url,  "root","");
      Statement stmt = conn.createStatement(); //创建Statement对象
      System.out.println("成功连接到数据库！");
      String sql = "select * from stu";  //要执行的SQL
      ResultSet rs = stmt.executeQuery(sql);//创建数据对象
        System.out.println("编号"+"\t"+"姓名"+"\t"+"年龄");
        while (rs.next()){
          System.out.print(rs.getInt(1) + "\t");
          System.out.print(rs.getString(2) + "\t");
          System.out.print(rs.getInt(3) + "\t");
          System.out.println();
        }
        rs.close();
        stmt.close();
        conn.close();
      }catch(Exception e)
      {
        e.printStackTrace();
      }
  }
}

3. 데이터베이스 수정 및 삭제

//修改删除数据
import java.sql.*;
public class UpdateDeleteDemo {
  public static void main(String[] args)throws Exception{
    try{
      //调用Class.forName()方法加载驱动程序
      Class.forName("com.mysql.jdbc.Driver");
      System.out.println("成功加载MySQL驱动！");
      String url="jdbc:mysql://localhost:3306/aniu";  //JDBC的URL
      Connection conn;
      conn = DriverManager.getConnection(url,  "root","");
      Statement stmt = conn.createStatement(); //创建Statement对象
      System.out.println("成功连接到数据库！");
      //查询数据的代码
      String sql = "select * from stu";  //要执行的SQL
      ResultSet rs = stmt.executeQuery(sql);//创建数据对象
        System.out.println("编号"+"\t"+"姓名"+"\t"+"年龄");
        while (rs.next()){
          System.out.print(rs.getInt(1) + "\t");
          System.out.print(rs.getString(2) + "\t");
          System.out.print(rs.getInt(3) + "\t");
          System.out.println();
        }
      //修改数据的代码
      String sql2 = "update stu set name=? where number=?";
      PreparedStatement pst = conn.prepareStatement(sql2);
      pst.setString(1,"8888");
      pst.setInt(2,198);
      pst.executeUpdate();
      //删除数据的代码
      String sql3 = "delete from stu where number=?";
      pst = conn.prepareStatement(sql3);
      pst.setInt(1,701);
      pst.executeUpdate();
      ResultSet rs2 = stmt.executeQuery(sql);//创建数据对象
      System.out.println("编号"+"\t"+"姓名"+"\t"+"年龄");
      while (rs.next()){
        System.out.print(rs2.getInt(1) + "\t");
        System.out.print(rs2.getString(2) + "\t");
        System.out.print(rs2.getInt(3) + "\t");
        System.out.println();
      }
      rs.close();
      stmt.close();
      conn.close();
      }catch(Exception e)
      {
        e.printStackTrace();
      }
  }
}

위 내용은 Java를 사용하여 MySQL을 쿼리, 수정 및 연결하는 방법에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!