Java JDBC işlemleri

Veri Listeleme

package com.burhan;
import java.net.ConnectException;
import java.sql.*;
public class sample1 {
static final String JDBC_Driver="com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost:3306/ilkmysql";

// database kimlik bilgileri
static final String USER="root";
static final String PASSWORD ="root";

public static void main(String[] args) throws ClassNotFoundException {

Connection conn=null;
Statement stmt=null;
try {
//2. aşama jdbc driver kayıt
Class.forName("com.mysql.jdbc.Driver");

// 3. aşama veri tabanına bağlan.
System.out.println("veri tabanına baglan.");
conn=DriverManager.getConnection(DB_URL,USER,PASSWORD);
// 4. aşama  sorgu oluştur
System.out.println("sorgu olustur.");
stmt=conn.createStatement();
String sql;
sql ="select *from filmler ";
ResultSet rs=stmt.executeQuery(sql);

//5. aşama resulset dönen değerleri aç

while(rs.next())
{
int filmid= rs.getInt("filmid");
String adi= rs.getString("adi");
int sene=rs.getInt("sene");


System.out.println("Filmin İd="+filmid);
System.out.println("Filmin Adi="+adi);
System.out.println("yapım yılı="+sene);
}
rs.close();
stmt.close();
conn.close();

}
catch (SQLException se)
{
se.printStackTrace();
}
//kapanması gereken kaynaklar için finaly blogu
finally
{
try 
{
if(stmt!=null)
stmt.close();
}
catch (SQLException se2) {
// burda bişey yapmıyoruz
}
try 
{
if(conn!=null)
conn.close();
}
catch (SQLException se2) {
se2.printStackTrace();
}
}
System.out.println("güle güle..");
}

}

Veri ekleme

package com.burhan;

import java.sql.*;

public class ekleme {

// JDBC sürücü adı ve veritabanı URL'si

 static final String JDBC_Driver="com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost:3306/ilkmysql";

// database kimlik bilgileri
static final String USER="root";
static final String PASSWORD ="root";

public static void main(String[] args) throws ClassNotFoundException {

Connection conn=null;
Statement stmt=null;
try {
//2. aşama jdbc driver kayıt
Class.forName("com.mysql.jdbc.Driver");

// 3. aşama veri tabanına bağlan.
System.out.println("veri tabanına baglan.");
conn=DriverManager.getConnection(DB_URL,USER,PASSWORD);

     

  // 4. aşama  sorgu oluştur ve veri değerlerini girin.

     System.out.println("Kayıtları tabloya ekleme ...");

     stmt = conn.createStatement();

     

     String sql = "INSERT INTO filmler VALUES (15, 'KARASİMSEK',2005)";

     stmt.executeUpdate(sql);

     sql = "INSERT INTO Registration VALUES (16, 'KARA MURAT', 1975)";

     stmt.executeUpdate(sql);

     sql = "INSERT INTO Registration VALUES (17, 'ELFİDA', 2000)";

     stmt.executeUpdate(sql);       

    

  }catch(SQLException se){

     

     se.printStackTrace();

  }catch(Exception e){

     

     e.printStackTrace();

  }finally{

    

     try{

        if(stmt!=null)

           conn.close();

     }catch(SQLException se){

     }

     try{

        if(conn!=null)

           conn.close();

     }catch(SQLException se){

        se.printStackTrace();

     }

  }

 

}

  }

Veri Silme 

package com.burhan;

import java.sql.*;

public class silme {

  static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  

  static final String DB_URL = "jdbc:mysql://localhost:3306/ilkmysql";

// database kimlik bilgileri

  static final String USER = "root";

  static final String PASSWORD = "root";

  

  public static void main(String[] args) {

  Connection conn = null;

  Statement stmt = null;

  try{

//2. aşama jdbc driver kayıt

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

  // 3. aşama veri tabanına bağlan.

     System.out.println("veri tabanına baglan.");

     conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);

     System.out.println("Bağlı veritabanı başarıyla bağlandı ...");

     

  // 4. aşama  sorgu oluştur  

     stmt = conn.createStatement();

     String sql = "DELETE FROM filmler WHERE filmid = 15";

     stmt.executeUpdate(sql);

     System.out.println("Kayıt Silindi");

     sql = "SELECT filmid, adi, sene FROM filmler";

     ResultSet rs = stmt.executeQuery(sql);

     

   //5. aşama resulset dönen değerleri aç

     while(rs.next()){

        

           int filmid= rs.getInt("filmid");

String adi= rs.getString("adi");

int sene=rs.getInt("sene");

System.out.println("Filmin İd="+filmid);

System.out.println("Filmin Adi="+adi);

System.out.println("yapım yılı="+sene);

     }

     rs.close();

  }catch(SQLException se){

     

     se.printStackTrace();

  }catch(Exception e){

     

     e.printStackTrace();

  }

  finally{

//kapanması gereken kaynaklar için finaly blogu

     try{

        if(stmt!=null)

           conn.close();

     }catch(SQLException se){

     }

  // burda bişey yapmıyoruz

     try{

        if(conn!=null)

           conn.close();

     }catch(SQLException se){

        se.printStackTrace();

     }

  }

 

}

}

Görüldüğü gibi İd numarası 15 olan karaşimşek filmimiz silindi.

Veri Güncelleme 

package com.burhan;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.Statement;

import java.sql.*;

public class update {

  static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  

   static final String DB_URL = "jdbc:mysql://localhost:3306/ilkmysql";

// database kimlik bilgileri

   static final String USER = "root";

   static final String PASSWORD = "root";

   

   public static void main(String[] args) {

   Connection conn = null;

   Statement stmt = null;

   try{

 //2. aşama jdbc driver kayıt

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

   // 3. aşama veri tabanına bağlan.

      System.out.println("veri tabanına baglan.");

      conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);

      System.out.println("Bağlı veritabanı başarıyla bağlandı ...");

     

     

     //4. aşama  sorgu oluştur

    

     stmt = conn.createStatement();

     String sql = "UPDATE filmler SET adi = 'dirilis_ertugryu'  WHERE filmid=13";

     stmt.executeUpdate(sql);

     sql = "SELECT filmid, adi, sene FROM filmler";

     ResultSet rs = stmt.executeQuery(sql);

     while(rs.next()){

      int filmid= rs.getInt("filmid");

String adi= rs.getString("adi");

int sene=rs.getInt("sene");

System.out.println("Filmin İd="+filmid);

System.out.println("Filmin Adi="+adi);

System.out.println("yapım yılı="+sene);

     }

     rs.close();

  }catch(SQLException se){

     

     se.printStackTrace();

  }catch(Exception e){

     

     e.printStackTrace();

  }finally{

     

      try{

         if(stmt!=null)

           conn.close();

     }catch(SQLException se){

     }

     try{

        if(conn!=null)

           conn.close();

     }catch(SQLException se){

        se.printStackTrace();

     }

  }

  

}

}

İd numarısı 13 olan Dirilis adlı filmimizin yeni adını güncelleme ile Diriliş Ertuğrul olarak değiştirdik.