refactor: 优化数据库兼容性

Author: zhou-hao

jetlinks-manager/authentication-manager/src/main/java/org/jetlinks/community/auth/service/terms/ThirdPartyUserTermBuilder.java

@@ -48,7 +48,7 @@ public SqlFragments createFragments(String columnFullName, RDBColumnMetadata col
             sqlFragments.addSql("not");
         }
         sqlFragments
-            .addSql("exists(select 1 from ",getTableName("s_third_party_user_bind",column)," _bind where _bind.user_id =", columnFullName);
+            .addSql("exists(select 1 from ",getTableName("s_third_party_user_bind",column)," bind_ where bind_.user_id =", columnFullName);
 
         if (CollectionUtils.isEmpty(term.getOptions())) {
             throw new I18nSupportException("error.query_conditions_are_not_specified", column.getName()+"$user-third$type");
@@ -60,7 +60,7 @@ public SqlFragments createFragments(String columnFullName, RDBColumnMetadata col
         Arrays.fill(args, "?");
         sqlFragments
             .addSql(
-                "and _bind.type = ? and _bind.provider in (", String.join(",", args), ")")
+                "and bind_.type = ? and bind_.provider in (", String.join(",", args), ")")
             .addParameter(type)
             .addParameter(idList);
 

jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/events/handler/DeviceProductDeployHandler.java

@@ -131,7 +131,7 @@ public void run(String... args) {
         productService
             .createQuery()
             .fetch()
-            .filter(product -> new Byte((byte) 1).equals(product.getState()))
+            .filter(product -> Byte.valueOf((byte) 1).equals(product.getState()))
             .flatMap(deviceProductEntity -> this
                 .doRegisterMetadata(deviceProductEntity.getId(), deviceProductEntity.getMetadata())
                 .onErrorResume(err -> {

jetlinks-manager/rule-engine-manager/src/main/java/org/jetlinks/community/rule/engine/service/terms/AlarmBindRuleTerm.java

@@ -59,11 +59,11 @@ public SqlFragments createFragments(String columnFullName,
         }
 
         sqlFragments
-            .addSql("exists(select 1 from ", getTableName("s_alarm_rule_bind", column), " _bind where _bind.rule_id =", columnFullName);
+            .addSql("exists(select 1 from ", getTableName("s_alarm_rule_bind", column), " bind_ where bind_.rule_id =", columnFullName);
 
         List<Object> alarmId = convertList(column, term);
         sqlFragments
-            .addSql("and _bind.alarm_id in (")
+            .addSql("and bind_.alarm_id in (")
             .add(SqlUtils.createQuestionMarks(alarmId.size()))
             //  )
             .add(SqlFragments.RIGHT_BRACKET)

jetlinks-manager/rule-engine-manager/src/main/java/org/jetlinks/community/rule/engine/service/terms/RuleBindAlarmTerm.java

@@ -78,19 +78,19 @@ public SqlFragments createFragments(String columnFullName,
             sqlFragments.addSql("not");
         }
         sqlFragments
-            .addSql("exists(select 1 from ", getTableName("s_alarm_rule_bind", column), " _bind where _bind.alarm_id =", columnFullName);
+            .addSql("exists(select 1 from ", getTableName("s_alarm_rule_bind", column), " bind_ where bind_.alarm_id =", columnFullName);
 
         sqlFragments
             .addSql(
-                "and _bind.rule_id in (",
+                "and bind_.rule_id in (",
                 bindTerm.ruleId.stream().map(r -> "?").collect(Collectors.joining(",")),
                 ")")
             .addParameter(bindTerm.ruleId);
 
         if (CollectionUtils.isNotEmpty(bindTerm.branchId)) {
             sqlFragments
                 .addSql(
-                    "and _bind.branch_index in (",
+                    "and bind_.branch_index in (",
                     bindTerm.branchId.stream().map(r -> "?").collect(Collectors.joining(",")),
                     ")")
                 .addParameter(bindTerm.branchId);