Herkese merhaba,

Bu örneğimizde java uygulamamız ile Mysql bağlantısı yapıp tabloya eleman ekleme ve silme işlemlerini yapacağız.

İlk olarak Mysql Connector indirmemiz gerekmektedir. İndirmek için aşağıdaki bağlantıyı kullanabilirsiniz.

https://dev.mysql.com/downloads/connector/j/

 

İşaretlediğim dosyayı bilgisayarımıza indiriyoruz. Daha sonra NETBEANS IDE’ sini çalıştırıp bu Mysql Connector dosyasını import etmemiz gerekmektedir. Bunun için :

Proje dosyalarımızın içerisinde bulunan Library klasörüne sağ tıklayıp Add JAR/Folder ‘ e tıklıyoruz. Daha sonra indirdiğimiz Connector’ un içerisinde bulunan mysql-connector-java-5.1.46-bin.jar isimli dosyayı buraya ekliyoruz.

Artık kodumuzu yazmaya geçebiliriz.


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.logging.Level;
import java.util.logging.Logger;

public class Baglanti {

private String kullaniciadi = "root";
private String parola = "";
private String db_ismi = "db";
private String host = "localhost";
private int port = 3306;
private Connection con = null;

private Statement statement = null;

public Baglanti() {
    String url = "jdbc:mysql://" + host + ":" + port + "/" + db_ismi + "?useUnicode=true&characterEncoding=utf8";
    try {
        Class.forName("com.mysql.jdbc.Driver");
    } catch (ClassNotFoundException ex) {
        System.out.println("Driver bulunamadi.");
    }
    try {
        con = DriverManager.getConnection(url, kullaniciadi, parola);
        System.out.println("Baglanti basarili.");
    } catch (SQLException ex) {
        ex.printStackTrace();
        System.out.println("Baglanti basarisiz.");
    }
}

public void calisansil(){
    try {
        statement = con.createStatement();
        String sorgu = "delete from calisanlar where id > 2";
        int deger = statement.executeUpdate(sorgu);
        System.out.println(deger + " adet silindi.");
    } catch (SQLException ex) {
        Logger.getLogger(Baglanti.class.getName()).log(Level.SEVERE, null, ex);
    }
}

public void calisanguncelle(){
    try {
        statement = con.createStatement();
        String sorgu = "update calisanlar set email = 'mustafamurat@gmail.com' where id = 1";
        statement.executeUpdate(sorgu);
    } catch (SQLException ex) {
        Logger.getLogger(Baglanti.class.getName()).log(Level.SEVERE, null, ex);
    }

}

public void calisanEkle(){
    try {
        statement = con.createStatement();
        String ad = "Semih";
        String soyad = "Aktaş";
        String email = "semih@gmail.com";
        String sorgu = "insert into calisanlar (ad,soyad,email) values (" + "'" + ad + "'," + "'" + soyad + "'," + "'" + email + "')";
        statement.executeUpdate(sorgu);
    } catch (SQLException ex) {
        Logger.getLogger(Baglanti.class.getName()).log(Level.SEVERE, null, ex);
    }
}

public void calisanlariGetir() {
    String sorgu = "Select * from calisanlar";
    try {
        statement = con.createStatement();
        ResultSet rs = statement.executeQuery(sorgu); //Güncelleme haric kullanılır.
        while (rs.next()) { //Okunacak veri var mı?
            int id = rs.getInt("id");
            String ad = rs.getString("ad");
            String soyad = rs.getString("soyad");
            String email = rs.getString("email");
            System.out.println(id + " " + ad + " " + soyad + " " + email);
        }
    } catch (SQLException ex) {
        Logger.getLogger(Baglanti.class.getName()).log(Level.SEVERE, null, ex);
    }
}

public static void main(String[] args) {
    Baglanti baglanti = new Baglanti();
    baglanti.calisanlariGetir();
    System.out.println("***********************");
    baglanti.calisanEkle();
    baglanti.calisanlariGetir();
    System.out.println("***********************");
    baglanti.calisanguncelle();
    baglanti.calisanlariGetir();
    System.out.println("***********************");
    baglanti.calisansil();
    baglanti.calisanlariGetir();
}
}