Jumat, 14 November 2008

Melakukan query select di Java (database mysql)

Sekarang mari kita mempelajari bagaimana melakukan query dalam hal ini query select lewat java. Misal database cobas dimana ada tabel yaitu : profile yang terdiri field (nama varchar(20), alamat varchar(30), kota varchar(20), telepon varchar(15)).

Berikut petikan source code untuk mengakses isi tabel profile di mysql :

import java.sql.*;

public class TesKoneksi {

String url = "jdbc:mysql://localhost:3306/cobas"; // sesuaikan dengan nama database.
String user = "root"; // sesuaikan dengan nama user.
String pass = ""; // sesuaikan dengan password.
Connection conn;

private void displaySQLErrors(SQLException se)
{
System.out.println("SQL Exception : " + se.getMessage());
System.out.println("SQL State : " + se.getSQLState());
System.out.println("Vendor Error : " + se.getErrorCode());
}

public void HelloToDB()
{
try
{
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException cnfe)
{
System.err.println(cnfe.getMessage());
System.exit(1);
}

try
{
conn = DriverManager.getConnection(url, user, pass);

} catch (SQLException se)
{
System.out.println("Koneksi gagal dilakukan");
System.err.println(se.getMessage());
}
}

public void executeSQL(){
try
{
//membuat statement
Statement stmt = conn.createStatement();
//membuat objek ResultSet
ResultSet rs;
//melakukan query untuk menselect
rs = stmt.executeQuery("select * from profile");
while(rs.next())
{
System.out.println(rs.getString("nama"));
System.out.println(rs.getString("alamat"));
System.out.println(rs.getString("kota"));
System.out.println(rs.getString("telepon"));
}
rs.close();
stmt.close();
conn.close();
} catch (SQLException se)
{
displaySQLErrors(se);
}
}

public static void main(String[] args) {
TesKoneksi hello = new TesKoneksi();
hello.HelloToDB();
hello.executeSQL();
}
}

Demikianlah tutorial singkat saya. Selamat mencoba

Tidak ada komentar: