From 3d7d6fa5922e9b52f1129b9eab6a836ca625631b Mon Sep 17 00:00:00 2001
From: xingfudeshi <xingfudeshi@vip.qq.com>
Date: Wed, 3 Apr 2019 17:56:41 +0800
Subject: [PATCH] fix #587 support for automatic table creation with JPA (#709)

---
 .../fescar/rm/datasource/StatementProxy.java   | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/rm-datasource/src/main/java/com/alibaba/fescar/rm/datasource/StatementProxy.java b/rm-datasource/src/main/java/com/alibaba/fescar/rm/datasource/StatementProxy.java
index f6409987f08..fac36d605df 100644
--- a/rm-datasource/src/main/java/com/alibaba/fescar/rm/datasource/StatementProxy.java
+++ b/rm-datasource/src/main/java/com/alibaba/fescar/rm/datasource/StatementProxy.java
@@ -26,9 +26,8 @@
 /**
  * The type Statement proxy.
  *
- * @author sharajava
- *
  * @param <T> the type parameter
+ * @author sharajava
  */
 public class StatementProxy<T extends Statement> extends AbstractStatementProxy<T> {
 
@@ -58,7 +57,7 @@ public StatementProxy(AbstractConnectionProxy connectionWrapper, T targetStateme
 
     @Override
     public ConnectionProxy getConnectionProxy() {
-        return (ConnectionProxy)super.getConnectionProxy();
+        return (ConnectionProxy) super.getConnectionProxy();
     }
 
     @Override
@@ -67,7 +66,7 @@ public ResultSet executeQuery(String sql) throws SQLException {
         return ExecuteTemplate.execute(this, new StatementCallback<ResultSet, T>() {
             @Override
             public ResultSet execute(Statement statement, Object... args) throws SQLException {
-                return statement.executeQuery((String)args[0]);
+                return statement.executeQuery((String) args[0]);
             }
         }, sql);
     }
@@ -78,15 +77,20 @@ public int executeUpdate(String sql) throws SQLException {
         return ExecuteTemplate.execute(this, new StatementCallback<Integer, T>() {
             @Override
             public Integer execute(Statement statement, Object... args) throws SQLException {
-                return statement.executeUpdate((String)args[0]);
+                return statement.executeUpdate((String) args[0]);
             }
         }, sql);
     }
 
     @Override
     public boolean execute(String sql) throws SQLException {
-        // TODO
-        return false;
+        this.targetSQL = sql;
+        return ExecuteTemplate.execute(this, new StatementCallback<Boolean, T>() {
+            @Override
+            public Boolean execute(T statement, Object... args) throws SQLException {
+                return statement.execute((String) args[0]);
+            }
+        }, sql);
     }
 
     @Override