SpringCloud2.0.5集成LCN分布式事物最新解决方案

package com.codingapi.tx.datasource.relational.txc; import com.codingapi.tx.datasource.relational.txc.parser.ExecutePaser; import com.codingapi.tx.datasource.relational.txc.parser.SQLType; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.InputStream; import java.io.Reader; import java.math.BigDecimal; import java.net.URL; import java.sql.Array; import java.sql.Blob; import java.sql.Clob; import java.sql.Date; import java.sql.NClob; import java.sql.ParameterMetaData; import java.sql.PreparedStatement; import java.sql.Ref; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.RowId; import java.sql.SQLException; import java.sql.SQLXML; import java.sql.Time; import java.sql.Timestamp; import java.util.ArrayList; import java.util.Calendar; import java.util.List; /** * [类描述] * * @author caican * @date 17/11/28 * @title [confluence页面的title] */ public class TxcPreparedStatement extends TxcStatement implements PreparedStatement { private static final Logger logger = LoggerFactory.getLogger(TxcPreparedStatement.class); public TxcPreparedStatement(PreparedStatement localPreparedStatement, AbstractTxcConnection abstractTxcConnection, String sql) { super(localPreparedStatement, abstractTxcConnection); this.sql = sql; } /** * 把这个参数缓存下来 有什么用？ */ private List<Object> paramsList = new ArrayList<>(); public int getParameterCount() throws SQLException { return getParameterMetaData().getParameterCount(); } public synchronized List<Object> getParamsList() { return this.paramsList; } private void addParam(int paramInt, Object paramObject1, Object paramObject2, Object paramObject3) throws SQLException { List<Object> paramsList = getParamsList(); paramsList.add(paramObject1); } private void addParam(int paramInt, Object paramObject1, Object paramObject2) throws SQLException { List<Object> paramsList = getParamsList(); paramsList.add(paramObject1); } private void addParam(int paramInt, Object paramObject) throws SQLException { List<Object> paramsList = getParamsList(); paramsList.add(paramObject); } @Override public void addBatch() throws SQLException { ((PreparedStatement) this.statement).addBatch(); } @Override public void clearParameters() throws SQLException { ((PreparedStatement) this.statement).clearParameters(); } @Override public boolean execute() throws SQLException { if (isInTxcTransaction()) { SQLType sqlType = ExecutePaser.parse(this); boolean execute = ((PreparedStatement) this.statement).execute(); ExecutePaser.after(this, sqlType); return execute; } return ((PreparedStatement) this.statement).execute(); } @Override public ResultSet executeQuery() throws SQLException { // 查询语句也要包装么？ return ((PreparedStatement) this.statement).executeQuery(); } @Override public int[] executeBatch() throws SQLException { if (isInTxcTransaction()) { ExecutePaser.parse(this); } return this.statement.executeBatch(); } @Override public int executeUpdate() throws SQLException { if (isInTxcTransaction()) { SQLType sqlType = ExecutePaser.parse(this); int num = ((PreparedStatement) this.statement).executeUpdate(); ExecutePaser.after(this, sqlType); return num; } return ((PreparedStatement) this.statement).executeUpdate(); } @Override public ResultSetMetaData getMetaData() throws SQLException { return ((PreparedStatement) this.statement).getMetaData(); } @Override public ParameterMetaData getParameterMetaData() throws SQLException { return ((PreparedStatement) this.statement).getParameterMetaData(); } @Override public void setArray(int paramInt, Array paramArray) throws SQLException { addParam(paramInt, paramArray); ((PreparedStatement) this.statement).setArray(paramInt, paramArray); } @Override public void setAsciiStream(int paramInt, InputStream paramInputStream) throws SQLException { addParam(paramInt, paramInputStream); ((PreparedStatement) this.statement).setAsciiStream(paramInt, paramInputStream); } @Override public void setAsciiStream(int paramInt1, InputStream paramInputStream, int paramInt2) throws SQLException { addParam(paramInt1, paramInputStream, paramInt2); ((PreparedStatement) this.statement).setAsciiStream(paramInt1, paramInputStream, paramInt2); } @Override public void setAsciiStream(int paramInt, InputStream paramInputStream, long paramLong) throws SQLException { addParam(paramInt, paramInputStream, paramLong); ((PreparedStatement) this.statement).setAsciiStream(paramInt, paramInputStream, paramLong); } @Override public void setBigDecimal(int paramInt, BigDecimal paramBigDecimal) throws SQLException { addParam(paramInt, paramBigDecimal); ((PreparedStatement) this.statement).setBigDecimal(paramInt, paramBigDecimal); } @Override public void setBinaryStream(int paramInt, InputStream paramInputStream) throws SQLException { addParam(paramInt, paramInputStream); ((PreparedStatement) this.statement).setBinaryStream(paramInt, paramInputStream); } @Override public void setBinaryStream(int paramInt1, InputStream paramInputStream, int paramInt2) throws SQLException { addParam(paramInt1, paramInputStream, paramInt2); ((PreparedStatement) this.statement).setBinaryStream(paramInt1, paramInputStream, paramInt2); } @Override public void setBinaryStream(int paramInt, InputStream paramInputStream, long paramLong) throws SQLException { addParam(paramInt, paramInputStream, paramLong); ((PreparedStatement) this.statement).setBinaryStream(paramInt, paramInputStream, paramLong); } @Override public void setBlob(int paramInt, Blob paramBlob) throws SQLException { addParam(paramInt, paramBlob); ((PreparedStatement) this.statement).setBlob(paramInt, paramBlob); } @Override public void setBlob(int paramInt, InputStream paramInputStream) throws SQLException { addParam(paramInt, paramInputStream); ((PreparedStatement) this.statement).setBlob(paramInt, paramInputStream); } @Override public void setBlob(int paramInt, InputStream paramInputStream, long paramLong) throws SQLException { addParam(paramInt, paramInputStream, paramLong); ((PreparedStatement) this.statement).setBlob(paramInt, paramInputStream, paramLong); } @Override public void setBoolean(int paramInt, boolean paramBoolean) throws SQLException { addParam(paramInt, paramBoolean); ((PreparedStatement) this.statement).setBoolean(paramInt, paramBoolean); } @Override public void setByte(int paramInt, byte paramByte) throws SQLException { addParam(paramInt, paramByte); ((PreparedStatement) this.statement).setByte(paramInt, paramByte); } @Override public void setBytes(int paramInt, byte[] paramArrayOfByte) throws SQLException { addParam(paramInt, paramArrayOfByte); ((PreparedStatement) this.statement).setBytes(paramInt, paramArrayOfByte); } @Override public void setCharacterStream(int paramInt, Reader paramReader) throws SQLException { addParam(paramInt, paramReader);