コネクション
日本語 | 接続 |
英語 | connection |
ふりがな | こねくしょん |
フリガナ | コネクション |
「接続」のこと。
ほとんどの場合、データベースにアクセスできように接続すること、もしくはその際に取得できるConnectionインターフェイスのインスタンスを指す。
SQLでデータベースにアクセスするためには、まず「どのデータベースに」接続するかを指定し、さらに「ユーザー名」と「パスワード」を入力する必要がある。これらを入力することで初めてデータベースにアクセスする許可が得られ、その許可の印に与えられるのが「コネクション」である。
JDBCの場合、コネクションはDriverManagerクラスのgetConnection()メソッドで取得する。その際、「どのデータベース」を指定するURLと、ユーザー名及びパスワードを渡す。
このメソッドはConnectionインターフェイスのインスタンスへの参照を返すため、このインターフェイスを使用してデータベースにアクセスする。たとえばStatementインターフェイスのインスタンスへの参照はConnectionインターフェイスのcreateStatement()メソッドで取得できる。
コネクションの取得はユーザーの認証等が必要なため、取得に時間が掛かる。その時間を省くため、通常は「コネクションプール」と呼ばれる「コネクションの貯え」を用意しておき、そこから貸し出すようにする。
ほとんどの場合、データベースにアクセスできように接続すること、もしくはその際に取得できるConnectionインターフェイスのインスタンスを指す。
SQLでデータベースにアクセスするためには、まず「どのデータベースに」接続するかを指定し、さらに「ユーザー名」と「パスワード」を入力する必要がある。これらを入力することで初めてデータベースにアクセスする許可が得られ、その許可の印に与えられるのが「コネクション」である。
JDBCの場合、コネクションはDriverManagerクラスのgetConnection()メソッドで取得する。その際、「どのデータベース」を指定するURLと、ユーザー名及びパスワードを渡す。
このメソッドはConnectionインターフェイスのインスタンスへの参照を返すため、このインターフェイスを使用してデータベースにアクセスする。たとえばStatementインターフェイスのインスタンスへの参照はConnectionインターフェイスのcreateStatement()メソッドで取得できる。
コネクションの取得はユーザーの認証等が必要なため、取得に時間が掛かる。その時間を省くため、通常は「コネクションプール」と呼ばれる「コネクションの貯え」を用意しておき、そこから貸し出すようにする。
参考サイト
// Sample.java
import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class Sample
{
public static void main( String[] args )
{
Connection conn = null;
PreparedStatement psCreate = null;
PreparedStatement psInsert = null;
Statement stmt = null;
ResultSet rs = null;
try
{
// この使用例の使用方法についてはSQLの項目を参照してください。
// まずJDBCドライバを読み込みます。
Class.forName( "org.hsqldb.jdbcDriver" );
// JDBCに接続してコネクションを取得します。
// このURLやユーザー名、パスワードはデータベースの設定によって異なります。、
String url = "jdbc:hsqldb:mem:aname";
String user = "sa";
String password = "";
// コネクションを取得します。
conn = DriverManager.getConnection( url, user, password );
// テスト用テーブルを作ります。
psCreate = null;
final String SQL_CREATE = "CREATE TABLE TABLE_TEST( NAME VARCHAR, VALUE INT );";
psCreate = conn.prepareStatement( SQL_CREATE );
psCreate.execute();
// そのテーブルに3行INSERTします。
final String SQL_INSERT = "INSERT INTO TABLE_TEST VALUES( ?, ? );";
psInsert = conn.prepareStatement( SQL_INSERT );
for( int iF1 = 0; iF1 < 3; ++iF1 )
{
psInsert.setString( 1, "ネーム" + iF1 );
psInsert.setInt( 2, iF1 );
psInsert.execute();
}
// INSERTしたデータをSELECTでクエリーします。
stmt = conn.createStatement();
final String SQL_SELECT = "SELECT NAME, VALUE FROM TABLE_TEST;";
rs = stmt.executeQuery( SQL_SELECT );
while( rs.next() )
{
String name = rs.getString( "NAME" );
int value = rs.getInt( "VALUE" );
System.out.println( name + ", " + value );
}
// ネーム0, 0
// ネーム1, 1
// ネーム2, 2
}
catch( SQLException e )
{
// SQLの実行で問題があった場合に投げられます。
e.printStackTrace();
}
catch( ClassNotFoundException e )
{
// JDBCドライバが存在しなかった場合に投げられます。
e.printStackTrace();
}
finally
{
if( rs != null )
{
try
{
rs.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
if( stmt != null )
{
try
{
stmt.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
if( psInsert != null )
{
try
{
psInsert.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
if( psCreate != null )
{
try
{
psCreate.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
if( conn != null )
{
try
{
conn.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
}
}
}
import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class Sample
{
public static void main( String[] args )
{
Connection conn = null;
PreparedStatement psCreate = null;
PreparedStatement psInsert = null;
Statement stmt = null;
ResultSet rs = null;
try
{
// この使用例の使用方法についてはSQLの項目を参照してください。
// まずJDBCドライバを読み込みます。
Class.forName( "org.hsqldb.jdbcDriver" );
// JDBCに接続してコネクションを取得します。
// このURLやユーザー名、パスワードはデータベースの設定によって異なります。、
String url = "jdbc:hsqldb:mem:aname";
String user = "sa";
String password = "";
// コネクションを取得します。
conn = DriverManager.getConnection( url, user, password );
// テスト用テーブルを作ります。
psCreate = null;
final String SQL_CREATE = "CREATE TABLE TABLE_TEST( NAME VARCHAR, VALUE INT );";
psCreate = conn.prepareStatement( SQL_CREATE );
psCreate.execute();
// そのテーブルに3行INSERTします。
final String SQL_INSERT = "INSERT INTO TABLE_TEST VALUES( ?, ? );";
psInsert = conn.prepareStatement( SQL_INSERT );
for( int iF1 = 0; iF1 < 3; ++iF1 )
{
psInsert.setString( 1, "ネーム" + iF1 );
psInsert.setInt( 2, iF1 );
psInsert.execute();
}
// INSERTしたデータをSELECTでクエリーします。
stmt = conn.createStatement();
final String SQL_SELECT = "SELECT NAME, VALUE FROM TABLE_TEST;";
rs = stmt.executeQuery( SQL_SELECT );
while( rs.next() )
{
String name = rs.getString( "NAME" );
int value = rs.getInt( "VALUE" );
System.out.println( name + ", " + value );
}
// ネーム0, 0
// ネーム1, 1
// ネーム2, 2
}
catch( SQLException e )
{
// SQLの実行で問題があった場合に投げられます。
e.printStackTrace();
}
catch( ClassNotFoundException e )
{
// JDBCドライバが存在しなかった場合に投げられます。
e.printStackTrace();
}
finally
{
if( rs != null )
{
try
{
rs.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
if( stmt != null )
{
try
{
stmt.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
if( psInsert != null )
{
try
{
psInsert.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
if( psCreate != null )
{
try
{
psCreate.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
if( conn != null )
{
try
{
conn.close();
}
catch( SQLException e )
{
// 各close()メソッドからもSQLException例外が
// 投げられるので、拾っておきます。
e.printStackTrace();
}
}
}
}
}
// Sample.java import java.sql.DriverManager; import java.sql.Connection; import java.sql.Statement; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; public class Sample { public static void main( String[] args ) { Connection conn = null; PreparedStatement psCreate = null; PreparedStatement psInsert = null; Statement stmt = null; ResultSet rs = null; try { // この使用例の使用方法についてはSQLの項目を参照してください。 // まずJDBCドライバを読み込みます。 Class.forName( "org.hsqldb.jdbcDriver" ); // JDBCに接続してコネクションを取得します。 // このURLやユーザー名、パスワードはデータベースの設定によって異なります。、 String url = "jdbc:hsqldb:mem:aname"; String user = "sa"; String password = ""; // コネクションを取得します。 conn = DriverManager.getConnection( url, user, password ); // テスト用テーブルを作ります。 psCreate = null; final String SQL_CREATE = "CREATE TABLE TABLE_TEST( NAME VARCHAR, VALUE INT );"; psCreate = conn.prepareStatement( SQL_CREATE ); psCreate.execute(); // そのテーブルに3行INSERTします。 final String SQL_INSERT = "INSERT INTO TABLE_TEST VALUES( ?, ? );"; psInsert = conn.prepareStatement( SQL_INSERT ); for( int iF1 = 0; iF1 < 3; ++iF1 ) { psInsert.setString( 1, "ネーム" + iF1 ); psInsert.setInt( 2, iF1 ); psInsert.execute(); } // INSERTしたデータをSELECTでクエリーします。 stmt = conn.createStatement(); final String SQL_SELECT = "SELECT NAME, VALUE FROM TABLE_TEST;"; rs = stmt.executeQuery( SQL_SELECT ); while( rs.next() ) { String name = rs.getString( "NAME" ); int value = rs.getInt( "VALUE" ); System.out.println( name + ", " + value ); } // ネーム0, 0 // ネーム1, 1 // ネーム2, 2 } catch( SQLException e ) { // SQLの実行で問題があった場合に投げられます。 e.printStackTrace(); } catch( ClassNotFoundException e ) { // JDBCドライバが存在しなかった場合に投げられます。 e.printStackTrace(); } finally { if( rs != null ) { try { rs.close(); } catch( SQLException e ) { // 各close()メソッドからもSQLException例外が // 投げられるので、拾っておきます。 e.printStackTrace(); } } if( stmt != null ) { try { stmt.close(); } catch( SQLException e ) { // 各close()メソッドからもSQLException例外が // 投げられるので、拾っておきます。 e.printStackTrace(); } } if( psInsert != null ) { try { psInsert.close(); } catch( SQLException e ) { // 各close()メソッドからもSQLException例外が // 投げられるので、拾っておきます。 e.printStackTrace(); } } if( psCreate != null ) { try { psCreate.close(); } catch( SQLException e ) { // 各close()メソッドからもSQLException例外が // 投げられるので、拾っておきます。 e.printStackTrace(); } } if( conn != null ) { try { conn.close(); } catch( SQLException e ) { // 各close()メソッドからもSQLException例外が // 投げられるので、拾っておきます。 e.printStackTrace(); } } } } }