kgdxpr 2 years ago
commit 9f1827bfe5

@ -0,0 +1,33 @@
# 查询数据库相应用户dsideal的所有序列
SELECT
*
FROM
pg_class
WHERE
relowner = (SELECT usesysid FROM pg_user WHERE usename = 'dsideal')
AND relkind = 'S'
# 查询所有表名字默认schema名字是public
SELECT
tablename
FROM
pg_tables
WHERE
schemaname = 'public'
# 查询已知表名tableName的所有字段的字段名、类型、是否为空、注释
SELECT
A.attname AS NAME,
format_type(A.atttypid, A.atttypmod) AS TYPE,
A.attnotnull AS NOTNULL,
col_description(A.attrelid, A.attnum) AS COMMENT
FROM
pg_class AS C,
pg_attribute AS A
WHERE
C.relname = 'tableName'
AND A.attnum > 0
AND A.attrelid = C.oid
# 需要注意修改一下
mysql:ifnull <--> pgsql:coalesce

@ -12,8 +12,8 @@ import java.util.List;
public class TestOpenGauss { public class TestOpenGauss {
public static void main(String[] args) { public static void main(String[] args) {
//读取库 //读取库
DruidPlugin druid = new DruidPlugin("jdbc:postgresql://10.10.14.62:5432/dsideal_db", "test", DruidPlugin druid = new DruidPlugin("jdbc:postgresql://10.10.14.62:5432/ccdjzswd_db", "dsideal",
"Test@123", "org.postgresql.Driver"); "DsideaL147258369", "org.postgresql.Driver");
druid.start(); druid.start();
ActiveRecordPlugin arp = new ActiveRecordPlugin(druid); ActiveRecordPlugin arp = new ActiveRecordPlugin(druid);

@ -27,11 +27,11 @@ public class ExamModel {
public Kv addPerson(String person_name, String ks, String tel) { public Kv addPerson(String person_name, String ks, String tel) {
Kv kv = Kv.create(); Kv kv = Kv.create();
//1、检查此人员是不是已经存在过 //1、检查此人员是不是已经存在过
String sql = "select count(1) as count from t_exam_person where person_name=? and tel=? and b_use=1"; String sql = "select count(1) as count from t_exam_person where person_name=? and tel=? and b_use=1 and end_time is not null";
int cnt = Db.findFirst(sql, person_name, tel).getInt("count"); int cnt = Db.findFirst(sql, person_name, tel).getInt("count");
if (cnt > 0) { if (cnt > 0) {
kv.set("success", false); kv.set("success", false);
kv.set("message", "当前人员已经进行过测试,不能重复进行!"); kv.set("message", "当前人员已经进行过测试并且已交卷,不能重复进行!");
return kv; return kv;
} }
//2、增加人员信息 //2、增加人员信息

@ -122,9 +122,9 @@ public class Start extends JFinalConfig {
//数据监控 //数据监控
druidPlugin.addFilter(new StatFilter()); druidPlugin.addFilter(new StatFilter());
//sql防注入 //sql防注入
WallFilter wall = new WallFilter(); //WallFilter wall = new WallFilter();
wall.setDbType("mysql"); //wall.setDbType("mysql");
druidPlugin.addFilter(wall); //druidPlugin.addFilter(wall);
me.add(druidPlugin); me.add(druidPlugin);
// 配置ActiveRecord插件 // 配置ActiveRecord插件

@ -3,6 +3,13 @@ driverClassName=com.mysql.cj.jdbc.Driver
user=root user=root
password=DsideaL147258369 password=DsideaL147258369
jdbcUrl=jdbc:mysql://10.10.14.169:22066/ccdjzswd_db?rewriteBatchedStatements=true&useUnicode=true&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai jdbcUrl=jdbc:mysql://10.10.14.169:22066/ccdjzswd_db?rewriteBatchedStatements=true&useUnicode=true&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
#driverClassName=org.postgresql.Driver
#user=dsideal
#password=DsideaL147258369
#jdbcUrl=jdbc:postgresql://10.10.14.62:5432/ccdjzswd_db
# redis ip # redis ip
redis_ip=10.10.14.169 redis_ip=10.10.14.169
# redis port # redis port

@ -3,6 +3,13 @@ driverClassName=com.mysql.cj.jdbc.Driver
user=root user=root
password=DsideaL147258369 password=DsideaL147258369
jdbcUrl=jdbc:mysql://10.10.14.169:22066/ccdjzswd_db?rewriteBatchedStatements=true&useUnicode=true&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai jdbcUrl=jdbc:mysql://10.10.14.169:22066/ccdjzswd_db?rewriteBatchedStatements=true&useUnicode=true&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
#driverClassName=org.postgresql.Driver
#user=dsideal
#password=DsideaL147258369
#jdbcUrl=jdbc:postgresql://10.10.14.62:5432/ccdjzswd_db
# redis ip # redis ip
redis_ip=10.10.14.169 redis_ip=10.10.14.169
# redis port # redis port

Loading…
Cancel
Save