Java 基礎教程

Java 流程控制

Java 数组

Java 面向对象(I)

Java 面向对象(II)

Java 面向对象(III)

Java 異常処理

Java 列表(List)

Java Queue(隊列)

Java Map集合

Java Set集合

Java 输入输出(I/O)

Java Reader/Writer

Javaの他のトピック

Java 9 新機能 Java 8 新機能

Java MySQL コネクション

この章では、JavaがJDBCを使用してMySQLデータベースに接続する方法を紹介します。

JavaがMySQLに接続するにはドライバーパッケージが必要で、最新版のダウンロードリンクは以下の通りです：http://dev.mysql.com/downloads/connector/j/

当サイトから提供されているjarパッケージをダウンロードして、解凍するとjarライブラリファイルが得られます。その後、対応するプロジェクトに该ライブラリファイルをインポートしてください。mysql-connector-java-5.1.39-bin.jar

このサンプルではEclipseを使用しており、jarパッケージをインポートします：

MySQL 8.0 以上のバージョンのデータベース接続は以下のように異なります：
1、MySQL 8.0 以上のバージョンのドライバーパッケージのバージョン mysql-connector-java-8.0.16.jar。
2、com.mysql.jdbc.Driver com.mysql.cj.jdbc.Driverに変更してください。
MySQL 8.0 以上のバージョンではSSL接続を設定する必要がなく、明示的に閉じる必要があります。
allowPublicKeyRetrieval=true により、クライアントがサーバーから公钥を取得することができます。
最後にCSTを設定する必要があります。
ドライバーのロードとデータベース接続方法は以下の通りです：
Class.forName("com.mysql.cj.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:mysql:")//localhost:3306/test_demo?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC","root","password");

テストデータを作成します

次に、MySQLでw3codebox データベースに、websites データテーブルを作成し、以下の構造です：

CREATE TABLE `websites` (
　　`id` int(11) NOT NULL AUTO_INCREMENT,
　　`name` char(20) NOT NULL DEFAULT '' COMMENT 'サイト名',
　　`url` varchar(255) NOT NULL DEFAULT '',
　　`alexa` int(11) NOT NULL DEFAULT '0' COMMENT 'Alexa 排名',
　　`country` char(10) NOT NULL DEFAULT '' COMMENT '国家',
　　PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=10　DEFAULT CHARSET=utf8;

データを挿入します：

INSERT INTO `websites` VALUES ('1', 'Google', 'https://www.google.cm/', ''1', 'USA'), ('2', '淘宝', 'https://www.taobao.com/', ''13', 'CN'), ('3', 'w3codebox//ja.oldtoolbag.com5892', ''), ('4', '微博', 'http://weibo.com/', ''20', 'CN'), ('5', 'Facebook', 'https://www.facebook.com/', ''3', 'USA');

データテーブルが以下のように表示されます：

データベース接続

以下の例では、JDBCを使用してMySQLデータベースに接続しています。ユーザー名、パスワードなどの一部のデータは、あなたの開発環境に応じて設定してください：

MySQLDemo.java ファイルコード：

package com.w3codebox.test;
　
import java.sql.*;
　
public class MySQLDemo {
　
　　　　//　MySQL　8.0 バージョン以下　-　JDBC　ドライバ名及びデータベース　URL
　　　　static　final　String　JDBC_DRIVER　=　"com.mysql.jdbc.Driver";　　
　　　　static　final　String　DB_URL　=　"jdbc:mysql://localhost:3306/w3codebox";
　
　　　　//　MySQL　8.0以降のバージョン　-　JDBC　ドライバ名及びデータベース　URL
　　　　//static　final　String　JDBC_DRIVER　=　"com.mysql.cj.jdbc.Driver";　　
　　　　//static　final　String　DB_URL　=　"jdbc:mysql://localhost:3306/w3codebox?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";
　
　
　　　　//　データベースのユーザー名とパスワードは、自分の設定に従ってください
　　　　static　final　String　USER　=　"root";
　　　　static　final　String　PASS　=　"123456";
　
　　　　public　static　void　main(String[]　args)　{
　　　　　　　　Connection　conn　=　null;
　　　　　　　　Statement　stmt　=　null;
　　　　　　　　try{
　　　　　　　　　　　　//　JDBC　ドライバを登録
　　　　　　　　　　　　Class.forName(JDBC_DRIVER);
　　　　　　　　
　　　　　　　　　　　　//　リンクを開く
　　　　　　　　　　　　System.out.println("データベースに接続...");
　　　　　　　　　　　　conn　=　DriverManager.getConnection(DB_URL,USER,PASS);
　　　　　　　　
　　　　　　　　　　　　//　クエリを実行
　　　　　　　　　　　　System.out.println("　Statementオブジェクトを例示...");
　　　　　　　　　　　　stmt　=　conn.createStatement();
　　　　　　　　　　　　String　sql;
　　　　　　　　　　　　sql　=　"SELECT　id,　name,　url　FROM　websites";
　　　　　　　　　　　　ResultSet　rs　=　stmt.executeQuery(sql);
　　　　　　　　
　　　　　　　　　　　　//　結果セットデータベースを展開
　　　　　　　　　　　　while(rs.next()){
　　　　　　　　　　　　　　　　//　フィールドで検索
　　　　　　　　　　　　　　　　int　id　　=　rs.getInt("id");
　　　　　　　　　　　　　　　　String　name　=　rs.getString("name");
　　　　　　　　　　　　　　　　String　url　=　rs.getString("url");
　　　　
　　　　　　　　　　　　　　　　//　データを出力
　　　　　　　　　　　　　　　　System.out.print("ID:　"　+　id);
　　　　　　　　　　　　　　　　System.out.print(",　サイト名:　"　+　name);
　　　　　　　　　　　　　　　　System.out.print(", サイト URL: ""　+　url);
　　　　　　　　　　　　　　　　System.out.print("\n");
　　　　　　　　　　　　}
　　　　　　　　　　　　//　完了後に閉じる
　　　　　　　　　　　　rs.close();
　　　　　　　　　　　　stmt.close();
　　　　　　　　　　　　conn.close();
　　　　　　　　}catch(SQLException se){
　　　　　　　　　　　　//　JDBC エラーの処理
　　　　　　　　　　　　se.printStackTrace();
　　　　　　　　}catch(Exception e){
　　　　　　　　　　　　//　e.printStackTrace();
　　　　　　　　　　　　finally{
　　　　　　　　}
　　　　　　　　　　　　//　リソースを閉じる
　　　　　　　　　　　　try{
　　　　　　　　　　　　　　　　catch(SQLException se
　　　　　　　　　　　　}2{
　　　　　　　　　　　　}//　何もしない
　　　　　　　　　　　　try{
　　　　　　　　　　　　　　　　if(conn!=null) conn.close();
　　　　　　　　　　　　}catch(SQLException se){
　　　　　　　　　　　　　　　　se.printStackTrace();
　　　　　　　　　　　　}
　　　　　　　　}
　　　　　　　　System.out.println("Goodbye!");
　　　　}
}

以下の例の実行結果は次のようになります：

Java 9 新機能 Java 8 新機能