add delete and update

qiujunlin · qiujunlin · commit 59525679b8b9 · 2021-09-10T11:05:56.000+08:00
diff --git a/APIJSONORM/src/main/java/apijson/orm/AbstractSQLConfig.java b/APIJSONORM/src/main/java/apijson/orm/AbstractSQLConfig.java
@@ -2587,7 +2587,7 @@ public String getSetString(RequestMethod method, Map<String, Object> content, bo
 		if (setString.isEmpty()) {
 			throw new IllegalArgumentException("PUT 请求必须在Table内设置要修改的 key:value ！");
 		}
-		return " SET " + setString;
+		return (isClickHouse()?" ":" SET ") + setString;
 	}
 
 	/**SET key = concat(key, 'value')
@@ -2665,9 +2665,15 @@ public static String getSQL(AbstractSQLConfig config) throws Exception {
 		case POST:
 			return "INSERT INTO " + tablePath + config.getColumnString() + " VALUES" + config.getValuesString();
 		case PUT:
-			return "UPDATE " + tablePath + config.getSetString() + config.getWhereString(true) + (config.isMySQL()||config.isClickHouse() ? config.getLimitString() : "");
+			if(config.isClickHouse()){
+				return  "ALTER TABLE " +  tablePath + " UPDATE"+ config.getSetString()+ config.getWhereString(true);
+			}
+			return "UPDATE " + tablePath + config.getSetString() + config.getWhereString(true) + (config.isMySQL() ? config.getLimitString() : "");
 		case DELETE:
-			return "DELETE FROM " + tablePath + config.getWhereString(true) + (config.isMySQL()||config.isClickHouse() ? config.getLimitString() : "");  // PostgreSQL 不允许 LIMIT
+			if(config.isClickHouse()){
+				return  "ALTER TABLE " +  tablePath + " DELETE" + config.getWhereString(true);
+			}
+			return "DELETE FROM " + tablePath + config.getWhereString(true) + (config.isMySQL() ? config.getLimitString() : "");  // PostgreSQL 不允许 LIMIT
 		default:
 			String explain = (config.isExplain() ? (config.isSQLServer() || config.isOracle() ? "SET STATISTICS PROFILE ON  " : "EXPLAIN ") : "");
 			if (config.isTest() && RequestMethod.isGetMethod(config.getMethod(), true)) {
