Database Connection

Kategori: Java , 24 Temmuz 2019 , JanFranco


Bu ve bir sonraki yazımızda Java üzerinden veritabanı işlemleri yapacağız. Ben MSSQL veritabanı kullanıyorum. İşlemlerde çok bir fark olmuyor ancak hangi veritabanı sistemini kullanıyorsak o veritabanı sistemi için yazılmış kütüphaneyi dahil etmeliyiz. Microsoft SQL için yazılmış kütüphaneyi buradan edinebilirsiniz:

https://mvnrepository.com/artifact/com.microsoft.sqlserver/mssql-jdbc

Ben Eclipse IDE kullanıyorum. Eclipse'de bir kütüphaneyi import etmek için (dışarıdan bir kütüphaneyi), Project Explorer üzerinden ilgili projeye sağ tıklayıp Properties yani özelliklere tıklayalım. Java Build Path ayarından Libraries sekmesine girelim ve Add External Jars butonuna tıklayalım. Kütüphaneyi seçip kaydedip kapatalım. Nasıl veritabanına bağlanacağımızı görelim. İlk olarak ConnectDB isminde bir sınıf açalım:


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class ConnectDB {

    private String conStr = "jdbc:sqlserver://localhost:1433;databaseName=forJava;user=janfranco;password=123456789";
    private Connection conn = null;

    public ConnectDB() {
        try {
            Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
            this.conn = DriverManager.getConnection(conStr);
            System.out.println("Bağlantı başarılı");
        } catch (ClassNotFoundException ex) {
            System.out.println("Class bulunamadı...");
        } catch (SQLException ex) {
            System.out.println("Bağlantı başarısız...");
        }
    }
    
    public void listQuery() throws SQLException{
        String query = "SELECT * FROM dbo.calisanlar";
        Statement statement = conn.createStatement();
        ResultSet resultSet = statement.executeQuery(query);
        System.out.println("Getiriliyor...");
        while(resultSet.next()){
            System.out.println(resultSet.getInt(1) + "   " + resultSet.getString(2) + "    " + resultSet.getString(3)
            + "    " + resultSet.getString(4));
        }
        
    }
    
    public void Query(String query) throws SQLException{
        Statement statement = conn.createStatement();
        int value = statement.executeUpdate(query);
        
        System.out.println("Güncellendi: " + value + " Satır");
         
    }
    
}
Burada conStr değişkenindeki name, user, password kısımlarını kendinize göre değiştirmelisiniz. Aynı şekilde listQuery methodunu da kendinize göre değiştirin. Main_class üzerinden obje oluşturalım, verileri görelim:

import java.sql.SQLException;

public class Main_class {
    
    public static void main(String[] args){
        
        ConnectDB connection = new ConnectDB();
        
        try {
        	//connection.Query("SORGU");
        	connection.listQuery();
        } catch (SQLException ex) {
            System.out.println("Hata");
        }
        
    }
    
}
Sonuçları görelim:

Bağlantı başarılı
Getiriliyor...
58   Jane    Franco    Medical
2   Jan    Franco    Bilişim


Sonraki Yazı: Database Connection, Commit, RollBack
Yorumlar

Henüz bir yorum bulunmuyor.
Yorum bırakın