package com.robert.RedisTest;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Calendar;

import java.util.concurrent.TimeUnit;

public class JDBCCountLockTest {

    private static String jdbcUrl = "jdbc:mysql://localhost:3306/test";

    private static String username = "test";

    private static String password = "test";

    public static void main(String[] args) {

        new Thread(new Runnable(){

            public void run(){

                try {

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

                    Connection connection = DriverManager.getConnection(jdbcUrl,username,password);

                    connection.setAutoCommit(false);

                    Statement st = connection.createStatement();

                    st.executeQuery("select count(1) num from table_name where mobile_phone = '13651969037' and rule_id='39' for update");

                    TimeUnit.SECONDS.sleep(5);

                    connection.commit();

                    System.out.println("Thread 1 commit "+Calendar.getInstance().getTime());

                } catch (ClassNotFoundException e) {

                    e.printStackTrace();

                } catch (SQLException e) {

                    e.printStackTrace();

                } catch (InterruptedException e) {

                    e.printStackTrace();

                }

            }

        }).start();

        new Thread(new Runnable(){

            public void run(){

                try {

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

                    Connection connection = DriverManager.getConnection(jdbcUrl,username,password);

                    connection.setAutoCommit(false);

                    Statement st = connection.createStatement();

                    TimeUnit.SECONDS.sleep(1);

                    st.executeQuery("select * from table_name where id=4139 for update");

                    System.out.println("Thread 2 executeQuery finish "+Calendar.getInstance().getTime());

                    String update_sql_1 = "update table_name set rule_id='40'  where id = '4139'";

                    st.executeUpdate(update_sql_1);

                    System.out.println("Thread 2 executeUpdate finish "+Calendar.getInstance().getTime());

                    connection.commit();

                } catch (ClassNotFoundException e) {

                    e.printStackTrace();

                } catch (SQLException e) {

                    e.printStackTrace();

                    e.printStackTrace();

                } catch (InterruptedException e) {

                    e.printStackTrace();

                }

            }

        }).start();

    }

}