TranscationTest.java

import java.sql.*;

public class TranscationTest {
	public static void main(String[] args) throws ClassNotFoundException, SQLException {

		Class.forName("com.mysql.jdbc.Driver");
		String url = "jdbc:mysql://185.44.192.164/book";
		Connection con = DriverManager.getConnection(url, "root", "godoro");

		try {

			if (con != null) {
				// otomatik commit olayını kaldırıyoruz.
				con.setAutoCommit(false);
				PreparedStatement insert = con.prepareStatement("insert Users(Name,Age) values(?,?)");
				insert.setString(1, "Yusuf");
				insert.setInt(2, 23);
				// insert işlemi gerçekleşiyor.
				int result = insert.executeUpdate();
				if (result == 1) {
					insert.close();
					// Log tablosuna bilgiler yazılıyor.
					PreparedStatement log = con.prepareStatement("insert Log(Username,Password) values(?,?)");
					log.setString(1, "Yusuf");
					log.setInt(2, 23);
					log.executeUpdate();
				}
				// Yapılan işlemlerin veritabanında gerçekleşmesi sağlanıyor.
				con.commit();
			}
		} catch (Exception e) {
			e.printStackTrace();
			try {
				System.out.println("rollback");
				// transcation’ın başına dönülüyor. Yapılan işlemler iptal
				// ediliyor.
				con.rollback();
			} catch (Exception ex) {
				ex.printStackTrace();
			}
		}
	}
}