Skip to content

Commit 4765e54

Browse files
qiujunlinqiujunlin
committed
添加请求方式代码
1 parent 6ac4946 commit 4765e54

File tree

5 files changed

+77
-25
lines changed

5 files changed

+77
-25
lines changed

‎APIJSONORM/src/main/java/apijson/orm/AbstractSQLConfig.java‎

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2699,9 +2699,15 @@ public static String getSQL(AbstractSQLConfig config) throws Exception {
26992699
case POST:
27002700
return "INSERT INTO " + tablePath + config.getColumnString() + " VALUES" + config.getValuesString();
27012701
case PUT:
2702-
return "UPDATE " + tablePath + config.getSetString() + config.getWhereString(true) + (config.isMySQL() || config.isClickHouse() ? config.getLimitString() : "");
2702+
if(config.isClickHouse()){
2703+
return "ALTER TABLE " + tablePath + " UPDATE" + config.getWhereString(true);
2704+
}
2705+
return "UPDATE " + tablePath + config.getSetString() + config.getWhereString(true) + (config.isMySQL() ? config.getLimitString() : "");
27032706
case DELETE:
2704-
return "DELETE FROM " + tablePath + config.getWhereString(true) + (config.isMySQL() || config.isClickHouse() ? config.getLimitString() : ""); // PostgreSQL 不允许 LIMIT
2707+
if(config.isClickHouse()){
2708+
return "ALTER TABLE " + tablePath + " DELETE" + config.getWhereString(true);
2709+
}
2710+
return "DELETE FROM " + tablePath + config.getWhereString(true) + (config.isMySQL() ? config.getLimitString() : ""); // PostgreSQL 不允许 LIMIT
27052711
default:
27062712
String explain = (config.isExplain() ? (config.isSQLServer() || config.isOracle() ? "SET STATISTICS PROFILE ON " : "EXPLAIN ") : "");
27072713
if (config.isTest() && RequestMethod.isGetMethod(config.getMethod(), true)) {

‎APIJSONORM/src/main/java/apijson/orm/FunctionsAndRaws.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -518,7 +518,7 @@ public class FunctionsAndRaws {
518518
SQL_FUNCTION_MAP.put("version", ""); //以字符串形式返回服务器版本。
519519
SQL_FUNCTION_MAP.put("uptime", "");//以秒为单位返回服务器的正常运行时间。
520520

521-
//clickhouse 数学函数
521+
//
522522
SQL_FUNCTION_MAP.put("least", ""); //返回a和b中最小的值。
523523
SQL_FUNCTION_MAP.put("greatest", ""); //返回a和b的最大值。
524524
SQL_FUNCTION_MAP.put("plus", ""); //plus(a, b), a + b operator¶计算数值的总和。

‎Demo/pom.xml‎

Lines changed: 19 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -45,27 +45,27 @@
4545
<!-- <version>0.3.1</version>-->
4646

4747
<!-- </dependency>-->
48-
<dependency>
49-
<groupId>ru.yandex.clickhouse</groupId>
50-
<artifactId>clickhouse-jdbc</artifactId>
51-
<version>0.3.1-patch</version>
52-
<exclusions>
53-
<exclusion>
54-
<groupId>com.fasterxml.jackson.core</groupId>
55-
<artifactId>jackson-core</artifactId>
56-
</exclusion>
57-
<exclusion>
58-
<groupId>com.fasterxml.jackson.core</groupId>
59-
<artifactId>jackson-databind</artifactId>
60-
</exclusion>
61-
62-
</exclusions>
63-
</dependency>
6448
<!-- <dependency>-->
65-
<!-- <groupId>cc.blynk.clickhouse</groupId>-->
66-
<!-- <artifactId>clickhouse4j</artifactId>-->
67-
<!-- <version>1.4.4</version>-->
49+
<!-- <groupId>ru.yandex.clickhouse</groupId>-->
50+
<!-- <artifactId>clickhouse-jdbc</artifactId>-->
51+
<!-- <version>0.3.1-patch</version>-->
52+
<!-- <exclusions>-->
53+
<!-- <exclusion>-->
54+
<!-- <groupId>com.fasterxml.jackson.core</groupId>-->
55+
<!-- <artifactId>jackson-core</artifactId>-->
56+
<!-- </exclusion>-->
57+
<!-- <exclusion>-->
58+
<!-- <groupId>com.fasterxml.jackson.core</groupId>-->
59+
<!-- <artifactId>jackson-databind</artifactId>-->
60+
<!-- </exclusion>-->
61+
62+
<!-- </exclusions>-->
6863
<!-- </dependency>-->
64+
<dependency>
65+
<groupId>cc.blynk.clickhouse</groupId>
66+
<artifactId>clickhouse4j</artifactId>
67+
<version>1.4.4</version>
68+
</dependency>
6969
<!-- <dependency>-->
7070
<!-- <groupId>ru.yandex.clickhouse</groupId>-->
7171
<!-- <artifactId>clickhouse-jdbc</artifactId>-->

‎Demo/src/main/java/apijson/demo/DemoApplication.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,8 @@ public SQLConfig createSQLConfig() {
4646
};
4747
try { //加载驱动程序
4848
Log.d(TAG, "尝试加载 clickhouse 驱动 <<<<<<<<<<<<<<<<<<<<< ");
49-
Class.forName("ru.yandex.clickhouse.ClickHouseDriver");
50-
//Class.forName("cc.blynk.clickhouse.ClickHouseDriver");
49+
//Class.forName("ru.yandex.clickhouse.ClickHouseDriver");
50+
Class.forName("cc.blynk.clickhouse.ClickHouseDriver");
5151
Log.d(TAG, "成功加载 clickhouse 驱动！>>>>>>>>>>>>>>>>>>>>> ");
5252
}
5353
catch (ClassNotFoundException e) {

‎Demo/src/main/java/apijson/demo/DemoController.java‎

Lines changed: 47 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,53 @@ public class DemoController extends APIJSONController {
4141
public Parser<Long> newParser(HttpSession session, RequestMethod method) {
4242
return super.newParser(session, method).setNeedVerify(false); //TODO 这里关闭校验，方便新手快速测试，实际线上项目建议开启
4343
}
44-
44+
/**计数
45+
* @param request 只用String，避免encode后未decode
46+
* @param session
47+
* @return
48+
* @see {@link RequestMethod#HEAD}
49+
*/
50+
@PostMapping("head")
51+
@Override
52+
public String head(@RequestBody String request, HttpSession session) {
53+
return super.head(request, session);
54+
}
55+
56+
/**限制性GET，request和response都非明文，浏览器看不到，用于对安全性要求高的GET请求
57+
* @param request 只用String，避免encode后未decode
58+
* @param session
59+
* @return
60+
* @see {@link RequestMethod#GETS}
61+
*/
62+
@PostMapping("gets")
63+
@Override
64+
public String gets(@RequestBody String request, HttpSession session) {
65+
return super.gets(request, session);
66+
}
67+
68+
/**限制性HEAD，request和response都非明文，浏览器看不到，用于对安全性要求高的HEAD请求
69+
* @param request 只用String，避免encode后未decode
70+
* @param session
71+
* @return
72+
* @see {@link RequestMethod#HEADS}
73+
*/
74+
@PostMapping("heads")
75+
@Override
76+
public String heads(@RequestBody String request, HttpSession session) {
77+
return super.heads(request, session);
78+
}
79+
/**修改
80+
* @param request 只用String，避免encode后未decode
81+
* @param session
82+
* @return
83+
* @see {@link RequestMethod#PUT}
84+
*/
85+
@PostMapping("put")
86+
@Override
87+
public String put(@RequestBody String request, HttpSession session) {
88+
return super.put(request, session);
89+
}
90+
4591
@PostMapping(value = "get")
4692
@Override
4793
public String get(@RequestBody String request, HttpSession session) {

0 commit comments

Comments
 (0)