Repository navigation
Expand file tree
/
Copy pathDemoSQLConfig.java
More file actions
executable file
·182 lines (147 loc) · 5.22 KB
/
Copy pathDemoSQLConfig.java
File metadata and controls
executable file
·182 lines (147 loc) · 5.22 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
/*Copyright ©2016 TommyLemon(https://github.com/TommyLemon/APIJSON)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.*/
package apijson.demo.server;
import static zuo.biao.apijson.JSONObject.KEY_ID;
import static zuo.biao.apijson.JSONObject.KEY_USER_ID;
import java.util.List;
import com.alibaba.fastjson.JSONObject;
import zuo.biao.apijson.RequestMethod;
import zuo.biao.apijson.server.AbstractSQLConfig;
import zuo.biao.apijson.server.Join;
import zuo.biao.apijson.server.SQLConfig;
/**SQL配置
* TiDB 用法和 MySQL 一致
* @author Lemon
*/
public class DemoSQLConfig extends AbstractSQLConfig {
public static final Callback SIMPLE_CALLBACK;
static {
//TODO 默认模式名，改成你自己的
DEFAULT_SCHEMA = "sys";
// 由 DemoVerifier.init 方法读取数据库 Access 表来替代手动输入配置
// //表名映射，隐藏真实表名，对安全要求很高的表可以这么做
// TABLE_KEY_MAP.put(User.class.getSimpleName(), "apijson_user");
// TABLE_KEY_MAP.put(Privacy.class.getSimpleName(), "apijson_privacy");
//主键名映射
SIMPLE_CALLBACK = new SimpleCallback() {
@Override
public AbstractSQLConfig getSQLConfig(RequestMethod method, String database, String schema, String table) {
return new DemoSQLConfig(method, table);
}
//取消注释来实现自定义各个表的主键名
// @Override
// public String getIdKey(String database, String schema, String table) {
// return StringUtil.firstCase(table + "Id"); // userId, comemntId ...
// // return StringUtil.toLowerCase(t) + "_id"; // user_id, comemnt_id ...
// // return StringUtil.toUpperCase(t) + "_ID"; // USER_ID, COMMENT_ID ...
// }
@Override
public String getUserIdKey(String database, String schema, String table) {
return Controller.USER_.equals(table) || Controller.PRIVACY_.equals(table) ? KEY_ID : KEY_USER_ID; // id / userId
}
};
}
//取消注释后，默认的数据库类型会由 MySQL 改为 PostgreSQL
// @Override
// public String getDatabase() {
// String db = super.getDatabase();
// return db == null ? DATABASE_POSTGRESQL : db;
// }
@Override
public String getDBVersion() {
return "5.7.22"; //"8.0.11"; //TODO 改成你自己的 MySQL 或 PostgreSQL 数据库版本号 //MYSQL 8 和 7 使用的 JDBC 配置不一样
}
@Override
public String getDBUri() {
String db = getDatabase();
if (db == null) {
db = "";
}
switch (db) {
case DATABASE_POSTGRESQL:
return "jdbc:postgresql://localhost:5432/postgres"; //TODO 改成你自己的
case DATABASE_SQLSERVER:
return "jdbc:jtds:sqlserver://localhost:1433/pubs;instance=SQLEXPRESS"; //TODO 改成你自己的
case DATABASE_ORACLE:
return "jdbc:oracle:thin:@localhost:1521:orcl"; //TODO 改成你自己的
case DATABASE_MYSQL:
default:
return "jdbc:mysql://localhost:3306"; //TODO 改成你自己的，TiDB 可以当成 MySQL 使用，默认端口为 4000
}
}
@Override
public String getDBAccount() {
String db = getDatabase();
if (db == null) {
db = "";
}
switch (db) {
case DATABASE_POSTGRESQL:
return "postgres"; //TODO 改成你自己的
case DATABASE_SQLSERVER:
return "sa"; //TODO 改成你自己的
case DATABASE_ORACLE:
return "scott"; //TODO 改成你自己的
case DATABASE_MYSQL:
default:
return "root"; //TODO 改成你自己的
}
}
@Override
public String getDBPassword() {
String db = getDatabase();
if (db == null) {
db = "";
}
switch (db) {
case DATABASE_POSTGRESQL:
return null; //TODO 改成你自己的
case DATABASE_SQLSERVER:
return "apijson@123"; //TODO 改成你自己的
case DATABASE_ORACLE:
return "tiger"; //TODO 改成你自己的
case DATABASE_MYSQL:
default:
return "apijson"; //TODO 改成你自己的，TiDB 可以当成 MySQL 使用， 默认密码为空字符串 ""
}
}
@Override
public String getIdKey() {
return SIMPLE_CALLBACK.getIdKey(getDatabase(), getSchema(), getTable());
}
@Override
public String getUserIdKey() {
return SIMPLE_CALLBACK.getUserIdKey(getDatabase(), getSchema(), getTable());
}
public DemoSQLConfig() {
this(RequestMethod.GET);
}
public DemoSQLConfig(RequestMethod method) {
super(method);
}
public DemoSQLConfig(RequestMethod method, String table) {
super(method, table);
}
public DemoSQLConfig(RequestMethod method, int count, int page) {
super(method, count, page);
}
/**获取SQL配置
* @param table
* @param alias
* @param request
* @param isProcedure
* @return
* @throws Exception
*/
public static SQLConfig newSQLConfig(RequestMethod method, String table, String alias, JSONObject request, List<Join> joinList, boolean isProcedure) throws Exception {
return newSQLConfig(method, table, alias, request, joinList, isProcedure, SIMPLE_CALLBACK);
}
}