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で、対応するプロジェクトを選択し、プロジェクト-プロパティのJavaビルドパスをクリックし、ライブラリに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 中国語 Web サイトの他の関連記事を参照してください。