From 4fe13e7fcf86216bb98bca83bfe1d19cf3ca50e8 Mon Sep 17 00:00:00 2001
From: kamhung <22250530@qq.com>
Date: Fri, 4 Dec 2015 11:45:41 +0800
Subject: [PATCH]

---
 src/com/wentch/redkale/source/DataDefaultSource.java | 6 +++++-
 src/com/wentch/redkale/source/JDBCPoolSource.java    | 4 ++++
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/src/com/wentch/redkale/source/DataDefaultSource.java b/src/com/wentch/redkale/source/DataDefaultSource.java
index fd8495a38..a52720966 100644
--- a/src/com/wentch/redkale/source/DataDefaultSource.java
+++ b/src/com/wentch/redkale/source/DataDefaultSource.java
@@ -52,6 +52,8 @@ public final class DataDefaultSource implements DataSource, Nameable, Function<C
 
     final boolean cacheForbidden;
 
+    private final boolean mysql;
+
     private final JDBCPoolSource readPool;
 
     private final JDBCPoolSource writePool;
@@ -155,6 +157,7 @@ public final class DataDefaultSource implements DataSource, Nameable, Function<C
         this.conf = url;
         this.readPool = new JDBCPoolSource(this, "read", readprop);
         this.writePool = new JDBCPoolSource(this, "write", writeprop);
+        this.mysql = this.writePool.isMysql();
         this.cacheForbidden = "NONE".equalsIgnoreCase(readprop.getProperty("shared-cache-mode"));
     }
 
@@ -163,6 +166,7 @@ public final class DataDefaultSource implements DataSource, Nameable, Function<C
         this.conf = null;
         this.readPool = new JDBCPoolSource(this, "read", readprop);
         this.writePool = new JDBCPoolSource(this, "write", writeprop);
+        this.mysql = this.writePool.isMysql();
         this.cacheForbidden = "NONE".equalsIgnoreCase(readprop.getProperty("shared-cache-mode"));
     }
 
@@ -648,7 +652,7 @@ public final class DataDefaultSource implements DataSource, Nameable, Function<C
                 Map<Class, String> joinTabalis = node.getJoinTabalis();
                 CharSequence join = node.createSQLJoin(this, joinTabalis, info);
                 CharSequence where = node.createSQLExpress(info, joinTabalis, null);
-                String sql = "DELETE a FROM " + info.getTable() + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
+                String sql = "DELETE " + (mysql ? "a" : "") + " FROM " + info.getTable() + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
                 if (debug.get()) logger.finest(info.getType().getSimpleName() + " delete sql=" + sql);
                 final Statement stmt = conn.createStatement();
                 stmt.execute(sql);
diff --git a/src/com/wentch/redkale/source/JDBCPoolSource.java b/src/com/wentch/redkale/source/JDBCPoolSource.java
index 892e32b7a..51fb3e938 100644
--- a/src/com/wentch/redkale/source/JDBCPoolSource.java
+++ b/src/com/wentch/redkale/source/JDBCPoolSource.java
@@ -83,6 +83,10 @@ public class JDBCPoolSource {
         }
     }
 
+    public boolean isMysql() {
+        return source != null && source.getClass().getName().contains(".mysql.");
+    }
+
     private void watch() throws IOException {
         if (dataSource.conf == null || dataSource.name == null) return;
         final String file = dataSource.conf.getFile();