/********************************/ /* テーブルへのデータの読み込み */ /* coded by Y.Suganuma */ /********************************/ import java.io.*; import java.sql.*; public class Test { public static void main(String args[]) { int i1, n_col; boolean s; ResultSet result; Connection Con; ResultSetMetaData rm; // JDBCドライバの登録 try { Class.forName("com.mysql.jdbc.Driver").newInstance(); } catch (Exception e1) { System.out.println("Driver Error: " + e1.toString()); } try { // データベースへの接続 Con = DriverManager.getConnection("jdbc:mysql://cs-www/mysql?" + "useUnicode=true&characterEncoding=sjis", "xxxxx", "*****"); try { // SQL の実行 Statement SQL = Con.createStatement(); // データベースの選択 SQL.execute("USE base"); // テーブルにデータを追加(ファイル test1.txt から) SQL.execute("LOAD DATA LOCAL INFILE \"test1.txt\" INTO TABLE gakuseki"); SQL.execute("SELECT * FROM gakuseki"); result = SQL.getResultSet(); rm = result.getMetaData(); n_col = rm.getColumnCount(); System.out.println("No, name, math"); while (result.next()) { System.out.print(" "); for (i1 = 1; i1 <= n_col; i1++) { if (i1 < n_col) System.out.print(result.getString(i1) + ", "); else System.out.print(result.getString(i1)); } System.out.println(); } // テーブルにデータを追加(ファイル test2.txt から) SQL.execute("LOAD DATA LOCAL INFILE \"test2.txt\" INTO TABLE gakuseki"); SQL.execute("SELECT * FROM gakuseki"); result = SQL.getResultSet(); rm = result.getMetaData(); n_col = rm.getColumnCount(); System.out.println("No, name, math"); while (result.next()) { System.out.print(" "); for (i1 = 1; i1 <= n_col; i1++) { if (i1 < n_col) System.out.print(result.getString(i1) + ", "); else System.out.print(result.getString(i1)); } System.out.println(); } // テーブルにデータを追加(INSERTコマンド) SQL.execute("INSERT INTO gakuseki VALUES(444444444,'杉山',40)"); SQL.execute("SELECT * FROM gakuseki"); result = SQL.getResultSet(); rm = result.getMetaData(); n_col = rm.getColumnCount(); System.out.println("No, name, math"); while (result.next()) { System.out.print(" "); for (i1 = 1; i1 <= n_col; i1++) { if (i1 < n_col) System.out.print(result.getString(i1) + ", "); else System.out.print(result.getString(i1)); } System.out.println(); } // テーブルにデータを追加(INSERTコマンド)→エラーになる SQL.execute("INSERT INTO gakuseki VALUES(222222222,'鈴木',100)"); // SQLを閉じる SQL.close(); // 接続を閉じる Con.close(); } catch (SQLException e2) { System.out.println("SQL Error: " + e2.toString()); } } catch (SQLException e3) { System.out.println("SQLException: " + e3.getMessage()); System.out.println("SQLState: " + e3.getSQLState()); System.out.println("VendorError: " + e3.getErrorCode()); } } }