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 e22c04617ec1c4d1ab4ad038774238f0b1c4242e Author: KomachiSion <[email protected]> AuthorDate: Mon Sep 3 15:57:43 2018 +0800 SCB-864 modify SQLTransport to support multiple parameters for each sql. --- .../main/java/org/apache/servicecomb/saga/core/SQLOperation.java | 8 ++++---- .../java/org/apache/servicecomb/saga/transports/SQLTransport.java | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/saga-core/src/main/java/org/apache/servicecomb/saga/core/SQLOperation.java b/saga-core/src/main/java/org/apache/servicecomb/saga/core/SQLOperation.java index 6444e2b..35dc9ef 100644 --- a/saga-core/src/main/java/org/apache/servicecomb/saga/core/SQLOperation.java +++ b/saga-core/src/main/java/org/apache/servicecomb/saga/core/SQLOperation.java @@ -23,18 +23,18 @@ import java.util.List; public class SQLOperation implements Operation { private final String sql; - private final List<String> params; + private final List<List<Object>> params; - public SQLOperation(String sql, List<String> params) { + public SQLOperation(String sql, List<List<Object>> params) { this.sql = sql; - this.params = params == null ? Collections.<String>emptyList() : params; + this.params = params == null ? Collections.<List<Object>>emptyList() : params; } public String sql() { return sql; } - public List<String> params() { + public List<List<Object>> params() { return params; } diff --git a/saga-core/src/main/java/org/apache/servicecomb/saga/transports/SQLTransport.java b/saga-core/src/main/java/org/apache/servicecomb/saga/transports/SQLTransport.java index 6e534dd..5d4c757 100644 --- a/saga-core/src/main/java/org/apache/servicecomb/saga/transports/SQLTransport.java +++ b/saga-core/src/main/java/org/apache/servicecomb/saga/transports/SQLTransport.java @@ -24,6 +24,6 @@ import org.apache.servicecomb.saga.core.Transport; public interface SQLTransport extends Transport { - SagaResponse with(String datasource, String sql, List<String> params); + SagaResponse with(String datasource, String sql, List<List<Object>> params); }
