2019独角兽企业重金招聘Python工程师标准>>> 
全局表
全局表说明
- 全局表配置使用type='global'
- 全局表数据增加或者修改时，节点之间保持数据一致
- 全局表只适合修改不频繁的表，例如字典表
全局表死锁
为了保持数据的一致性，当全局表更新数据时会通过锁机制来保证数据统一。
当时这也导致了并发更新的时候死锁的发生，全局表需要慎用。
以下是测试代码:
z_dict表配置的为全局表
两个线程并发更新一条记录
基本上每次都会造成锁超时的问题
public static void testThreadUpdate(DataSourceFactory ds) throws SQLException {
Connection con1 = ds.getConnection();
Connection con2 = ds.getConnection();
UpdateThread thread1 = new UpdateThread(con1, "update z_dict set name=? where id=?", new ArrayList<String>() {
private static final long serialVersionUID = 1L;
{
add("Q1");
add("1");
}
});
UpdateThread thread2 = new UpdateThread(con2, "update z_dict set name=? where id=?", new ArrayList<String>() {
private static final long serialVersionUID = 1L;
{
add("Q2");
add("1");
}
});
thread1.start();
thread2.start();
try {
Thread.sleep(60000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
package com.am.mycatclient;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;
public class UpdateThread extends Thread {
private Connection con;
private List<String> values;
private PreparedStatement ps;
public UpdateThread(Connection con, String updateSql, List<String> values) {
super();
this.con = con;
this.values = values;
try {
con.setAutoCommit(false);
ps = con.prepareStatement(updateSql);
} catch (SQLException e) {
e.printStackTrace();
}
}
@Override
public void run() {
try {
for (int i = 1; i <= values.size(); i++) {
ps.setString(i, values.get(i - 1));
}
int executeUpdate = ps.executeUpdate();
System.out.println("=="+executeUpdate);
con.commit();
ps.close();
con.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}