Membuat Class Koneksi ke Database(tugas 13)

Membuat Class Koneksi ke Database

ketikan connekdb lalu ketik finish

package project_penjualan;

import java.sql.*;

/**

 *

 * @author ismail

 */

public class ConekDB {

    public static void main(String[] args){

    }

    public Connection konek()throws SQLException{

        Connection Cn=null;

        try{

            Class.forName("com.mysql.jdbc.Driver");

            System.out.println("driver berhasil ditemukan");

           try{

               String url="jdbc:mysql://localhost/penjualan";

               String user="root";

                            String password="";

                            Cn=DriverManager.getConnection(url, user, password);

                            System.out.println("buat koneksi sukses");

                            return Cn;

           }catch(SQLException ex){

               System.out.println("koneksi gagal");

               System.out.println("SQLException:"+ ex.getMessage());

               return null;

           }

        }catch(Exception se){

            System.out.println("Driver MySQL tidak ditemukan:"+se);

            return null;

        }

    }

}

Selanjutnya membuat class data java

/*

 * To change this template, choose Tools | Templates

 * and open the template in the editor.

 */

package project_penjualan;

import java.sql.*;

import javax.swing.*;

/**

 *

 * @author ismail

 */

public class Data {

    Connection cnExecute=null;

    int rowNgefek=0;

    Statement stExecute;

   

   

    public void closingConnection(Connection cnClose,Statement stClose)

    {

        try

        {

            cnClose.close();

            stClose.close();

        }

    catch(SQLException e)

    {

    }

    }

       

        public void ExecuteSQL(String SQL)

        {

            ConekDB getCn=new ConekDB();

            rowNgefek=0;

            try{

                cnExecute=getCn.konek();

                stExecute=cnExecute.createStatement();

                cnExecute.setAutoCommit(false);

                rowNgefek=stExecute.executeUpdate(SQL);

                cnExecute.commit();

                closingConnection(cnExecute,stExecute);

            }

            catch(SQLException e)

            {

                System.out.println(e.toString());

                JOptionPane.showMessageDialog(null,

             e.toString(),"warning",JOptionPane.OK_OPTION);

            }

        }

    }