From c27d78ea44cb76d89c21af00a17822e50e22f3d4 Mon Sep 17 00:00:00 2001
From: yanhuqing666 <yanhuqing666@gmail.com>
Date: Thu, 15 Dec 2016 10:31:24 +0800
Subject: [PATCH] RecordTxn config from boolean to int

---
 Release_Note.md                                          | 2 +-
 src/main/java/io/mycat/MycatServer.java                  | 2 +-
 src/main/java/io/mycat/config/model/SystemConfig.java    | 6 +++---
 src/main/java/io/mycat/log/transaction/TxnLogHelper.java | 2 +-
 src/main/resources/server_template.xml                   | 2 +-
 5 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/Release_Note.md b/Release_Note.md
index 57d692f25..08ab0a173 100644
--- a/Release_Note.md
+++ b/Release_Note.md
@@ -21,7 +21,7 @@ server.xml 文件中  system标签 下
 <property name="xaLogCleanPeriod">1000</property <!-- 使用XA时，已经完结的XA LOG 会定时移除，默认1000毫秒 -->
 <property name="checkTableConsistency">0</property><!-- 是否进行meta数据定时巡检，默认不启用 -->
 <property name="checkTableConsistencyPeriod"> 60000</property><!-- meta数据定时巡检周期，默认60000毫秒 -->
-<property name="recordTxn">false</property>  <!-- true为开启事务日志记录、false为关闭 ，以后改为 0,1 -->
+<property name="recordTxn">0</property>  <!-- 1为开启事务日志记录、0为关闭-->
 ```
 
 也可见server_template.xml 
diff --git a/src/main/java/io/mycat/MycatServer.java b/src/main/java/io/mycat/MycatServer.java
index f5cbf03a2..1f9c75155 100644
--- a/src/main/java/io/mycat/MycatServer.java
+++ b/src/main/java/io/mycat/MycatServer.java
@@ -430,7 +430,7 @@ public class MycatServer {
 		}
 
 		// start transaction SQL log
-		if (config.getSystem().isRecordTxn()) {
+		if (config.getSystem().getRecordTxn() == 1) {
 			txnLogProcessor = new TxnLogProcessor(bufferPool);
 			txnLogProcessor.setName("TxnLogProcessor");
 			txnLogProcessor.start();
diff --git a/src/main/java/io/mycat/config/model/SystemConfig.java b/src/main/java/io/mycat/config/model/SystemConfig.java
index 0e326d18f..1e53049ed 100644
--- a/src/main/java/io/mycat/config/model/SystemConfig.java
+++ b/src/main/java/io/mycat/config/model/SystemConfig.java
@@ -121,7 +121,7 @@ public final class SystemConfig {
 	private int txIsolation;
 	private int parserCommentVersion;
 	private int sqlRecordCount;
-	private boolean recordTxn = false;
+	private int recordTxn = 0;
 	// a page size
 	private int bufferPoolPageSize;
 	//minimum allocation unit
@@ -687,11 +687,11 @@ public final class SystemConfig {
 		this.sqlRecordCount = sqlRecordCount;
 	}
 
-	public boolean isRecordTxn(){
+	public int getRecordTxn(){
 		return recordTxn;
 	}
 
-	public void setRecordTxn(boolean recordTxn){
+	public void setRecordTxn(int recordTxn){
 		this.recordTxn = recordTxn;
 	}
 
diff --git a/src/main/java/io/mycat/log/transaction/TxnLogHelper.java b/src/main/java/io/mycat/log/transaction/TxnLogHelper.java
index 4077435a4..e6af35ca6 100644
--- a/src/main/java/io/mycat/log/transaction/TxnLogHelper.java
+++ b/src/main/java/io/mycat/log/transaction/TxnLogHelper.java
@@ -5,7 +5,7 @@ import io.mycat.server.ServerConnection;
 
 public class TxnLogHelper {
 	public static void putTxnLog(ServerConnection c, String sql){
-		if (MycatServer.getInstance().getConfig().getSystem().isRecordTxn()) {
+		if (MycatServer.getInstance().getConfig().getSystem().getRecordTxn() == 1) {
 			MycatServer.getInstance().getTxnLogProcessor().putTxnLog(c, sql);
 		}
 	}
diff --git a/src/main/resources/server_template.xml b/src/main/resources/server_template.xml
index a08daa83b..6fba02852 100644
--- a/src/main/resources/server_template.xml
+++ b/src/main/resources/server_template.xml
@@ -17,7 +17,7 @@
 	<property name="useHandshakeV10">1</property>
 	<property name="useSqlStat">0</property>  <!-- 1为开启实时统计、0为关闭 -->
 	<property name="useGlobleTableCheck">0</property>  <!-- 1为开启全加班一致性检测、0为关闭 -->
-<property name="recordTxn">false</property>  <!-- true为开启事务日志记录、false为关闭 ，以后改为 0,1 -->
+	<property name="recordTxn">0</property>  <!-- 1为开启事务日志记录、0为关闭-->
 		<property name="sequnceHandlerType">2</property>
       <!--  <property name="useCompression">1</property>--> <!--1为开启mysql压缩协议-->
         <!--  <property name="fakeMySQLVersion">5.6.20</property>--> <!--设置模拟的MySQL版本号-->