koneksi jdbc mysql

Posted: 15 Mei 2010 in programming

berikut adalah source code untuk mengakses jdbc mysql.

terdapat juga method untuk melaksanakan query mysql. jadi pada class yang mengimplementasikan class ini cukup hanya mengakses methodnya.

file koneksi.java ada pada package konektor_mysql.

kekurangannya adalah belum menemukas script untuk membuka dan menutup koneksi. guna untuk membuka  dan menutup koneksi adalah menghemat resource ketika tidak digunakan.

berikut koneksi.java pada package konektor_mysql

/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/

package konektor_mysql;
import java.sql.*;
import javax.swing.*;
/**
*
* @author tarecha
*/
public class koneksi
{
public String sql=””;
public Connection koneksi_mysql;
public ResultSet rs;
public Statement statement;
String hasilQuery1;
String driver=”com.mysql.jdbc.Driver”;
String host=”localhost”;
String username=”root”;
String password=””;
String port=”3306″;
String database=”tarecha”;
String url=”jdbc:mysql://” +
host + “:” +
port + “/” +
database;
String parameter=”&tcpKeepAlive=true&autoReconnect=true&allowMultiQueries=true”;
String str_koneksi=url+”?user=”+username+”&password=”+password+parameter;

public koneksi()

{
openKoneksi();

}
public  void openKoneksi()
{
try
{
Class.forName(driver).newInstance();
koneksi_mysql=DriverManager.getConnection(str_koneksi);
statement=koneksi_mysql.createStatement();

}
catch(SQLException ex)
{
JOptionPane.showMessageDialog(null, “Warning 1 !\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}
catch(Exception ex)
{
JOptionPane.showMessageDialog(null, “Warning 2!\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}

finally
{

}
}
public   void closeKoneksi()
{
try
{
SQLWarning a =  statement.getWarnings();
// statement.close();
// rs.close();
//result set bisa ditutup tapi untuk membuka belum ketemu
//  koneksi_mysql.close();
//sql warning untuk mengalihkan try cactch saja

}
catch(SQLException ex)
{
JOptionPane.showMessageDialog(null, “Warning 1 !\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}
catch(Exception ex)
{
JOptionPane.showMessageDialog(null, “Warning 2!\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}

finally
{

}
}

public void queryUpdate(String sqlQuery)
{
try
{
openKoneksi();
statement.executeUpdate(sqlQuery);

closeKoneksi();

}
catch(SQLException ex)
{
JOptionPane.showMessageDialog(null, “Warning 3 !\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}
catch(Exception ex)
{
JOptionPane.showMessageDialog(null, “Warning 4 !\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}

finally
{

}

}
public void querySelect(String sqlQuery)
{
try
{
openKoneksi();
rs = statement.executeQuery(sqlQuery);
closeKoneksi();

}
catch(SQLException ex)
{
JOptionPane.showMessageDialog(null, “Warning 5 !\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}
catch(Exception ex)
{
JOptionPane.showMessageDialog(null, “Warning 6 !\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}

finally
{

}

}
public String querySelect(String sqlQuery, String kolomHasil)
{
try
{
openKoneksi();
hasilQuery1=null;
rs = statement.executeQuery(sqlQuery);
while(rs.next())

{
hasilQuery1=(rs.getString(kolomHasil));

}
if(hasilQuery1==null)

JOptionPane.showMessageDialog(null, kolomHasil + ” tidak ditemukan”,”Warning”,JOptionPane.WARNING_MESSAGE);

closeKoneksi();
}
catch(SQLException ex)
{
JOptionPane.showMessageDialog(null, “Warning 7 !\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}
catch(Exception ex)
{
JOptionPane.showMessageDialog(null, “Warning 8 !\n” +
“Error @ ” + ex.getMessage(),
“Warning”,JOptionPane.WARNING_MESSAGE);
}

finally
{
return hasilQuery1;
}

}

}

berikut adalah implementasi dari class koneksi. untuk mengeksekusi quey tinggal memanggil methodnya. berikut tugas_2.java

/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/

package modul_9;

import java.sql.SQLException;
import konektor_mysql.koneksi;
import javax.swing.*;
/**
*
* @author tarecha
*/
public class tugas_2
{
public static void main(String[] args) throws SQLException
{
koneksi koneksiku=new koneksi();
koneksiku.sql=”select curdate()”;
String tanggal=koneksiku.querySelect(koneksiku.sql,”curdate()”);
System.out.println(“Tanggal : ” + tanggal);
koneksiku.sql=”select curtime()”;
tanggal=koneksiku.querySelect(koneksiku.sql,”curtime()”);
System.out.println(“Waktu   : ” + tanggal);

koneksiku.sql=
“insert into tb_pegawai values(‘1′,’agung tarecha’);” +
“insert into tb_pegawai values(‘2′,’imam tarecha’);”;
koneksiku.queryUpdate(koneksiku.sql);

koneksiku.sql=”select * from tb_pegawai”;
koneksiku.querySelect(koneksiku.sql);

koneksiku.openKoneksi();
while(koneksiku.rs.next())
{
System.out.print(“No. : ” + koneksiku.rs.getString(“no”));
System.out.println(” Nama : ” + koneksiku.rs.getString(“nama”));
}
koneksiku.closeKoneksi();

}

}

berikut hasil yang didapat

hasil compile

Tinggalkan Balasan

Please log in using one of these methods to post your comment:

Logo WordPress.com

You are commenting using your WordPress.com account. Logout / Ubah )

Gambar Twitter

You are commenting using your Twitter account. Logout / Ubah )

Foto Facebook

You are commenting using your Facebook account. Logout / Ubah )

Foto Google+

You are commenting using your Google+ account. Logout / Ubah )

Connecting to %s