This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git
commit 948151bdd784f93b16912267220b39b2d65bf6ba Author: KomachiSion <[email protected]> AuthorDate: Mon Sep 3 15:59:25 2018 +0800 SCB-864 modify SQLTransport to support multiple parameters for each sql. --- .../org/apache/servicecomb/saga/format/JacksonSQLCompensation.java | 4 ++-- .../java/org/apache/servicecomb/saga/format/JacksonSQLOperation.java | 2 +- .../org/apache/servicecomb/saga/format/JacksonSQLTransaction.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLCompensation.java b/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLCompensation.java index 6a61bf3..5d2e6c1 100644 --- a/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLCompensation.java +++ b/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLCompensation.java @@ -28,14 +28,14 @@ public class JacksonSQLCompensation extends JacksonSQLOperation implements Compe private final int retries; - public JacksonSQLCompensation(String sql, List<String> params) { + public JacksonSQLCompensation(String sql, List<List<Object>> params) { this(sql, params, DEFAULT_RETRIES); } @JsonCreator public JacksonSQLCompensation( @JsonProperty("sql") String sql, - @JsonProperty("params") List<String> params, + @JsonProperty("params") List<List<Object>> params, @JsonProperty("retries") int retries) { super(sql, params); this.retries = retries <= 0? DEFAULT_RETRIES : retries; diff --git a/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLOperation.java b/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLOperation.java index 500bdfd..d164cd9 100644 --- a/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLOperation.java +++ b/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLOperation.java @@ -32,7 +32,7 @@ public class JacksonSQLOperation extends SQLOperation implements TransportAware< @JsonIgnore private SQLTransport transport; - public JacksonSQLOperation(String sql, List<String> params) { + public JacksonSQLOperation(String sql, List<List<Object>> params) { super(sql, params); } diff --git a/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLTransaction.java b/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLTransaction.java index e85c036..8176ed1 100644 --- a/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLTransaction.java +++ b/saga-format/src/main/java/org/apache/servicecomb/saga/format/JacksonSQLTransaction.java @@ -29,7 +29,7 @@ public class JacksonSQLTransaction extends JacksonSQLOperation implements Transa @JsonCreator public JacksonSQLTransaction( @JsonProperty("sql") String sql, - @JsonProperty("params") List<String> params) { + @JsonProperty("params") List<List<Object>> params) { super(sql, params); } }
