Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.sql.Connection;
- import java.sql.DriverManager;
- import java.sql.SQLException;
- import java.sql.Statement;
- import static java.lang.Thread.sleep;
- /**
- * Created by bogdan on 12.05.16.
- */
- public class Main {
- static public void main(String[] args){
- String login = "root";
- String password = "987654321";
- String url = "jdbc:mysql://localhost:3306/fifth";
- Thread first = new Thread(){
- public void run(){
- try {
- Class.forName("com.mysql.jdbc.Driver");
- Connection connection = DriverManager.getConnection(url, login, password);
- connection.setAutoCommit(false);
- Statement stmt = connection.createStatement();
- stmt.executeUpdate("update rooms set name='fromThread1' where id=2 ");
- try {
- sleep(100);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- stmt.executeUpdate("update inhabitan set name='fromThread1' where id=1 ");
- connection.commit();
- stmt.close();
- } catch (ClassNotFoundException e) {
- e.printStackTrace();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- };
- Thread second = new Thread(){
- public void run(){
- try {
- Class.forName("com.mysql.jdbc.Driver");
- Connection connection = DriverManager.getConnection(url, login, password);
- connection.setAutoCommit(false);
- Statement stmt = connection.createStatement();
- stmt.executeUpdate("update inhabitan set name='fromThread2' where id=1 ");
- try {
- sleep(100);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- stmt.executeUpdate("update rooms set name='fromThread2' where id=2 ");
- connection.commit();
- stmt.close();
- } catch (ClassNotFoundException e) {
- e.printStackTrace();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- };
- first.start();
- second.start();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement