压缩视频

yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/TableSqlCache.java

@@ -279,7 +279,18 @@ public class TableSqlCache {
      * @param fields  字段
      */
     public void addExist(String sqlName, String... fields) {
-        this.table.addExist(this, sqlName, fields);
+        this.addExist(sqlName, null, new TableFieldString(fields));
+    }
+
+    /**
+     * 生成该字段值是否存在的SQL语句
+     *
+     * @param sqlName        SQL语句名称
+     * @param mustField      必须输入字段
+     * @param allowNullField 允许为空字段
+     */
+    public void addExist(String sqlName, TableFieldString mustField, TableFieldString allowNullField) {
+        this.table.addExist(this, sqlName, mustField, allowNullField);
     }
 
     private void addString(Map<String, StringBuilder> map, String name, String value) {

yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/TableStruct.java

@@ -680,11 +680,14 @@ public class TableStruct {
     /**
      * 生成判断数据是否存在的SQL语句
      *
-     * @param sqlTableData 表结构
-     * @param sqlName      SQL语句的名称
-     * @param fields       需要判断的字段
+     * @param sqlTableData   表结构
+     * @param sqlName        SQL语句的名称
+     * @param mustField      需要判断的字段
+     * @param allowNullField 需要判断的字段
      */
-    public void addExist(TableSqlCache sqlTableData, String sqlName, String[] fields) {
+    public void addExist(TableSqlCache sqlTableData, String sqlName, TableFieldString mustField, TableFieldString allowNullField) {
+        // String[] fields
+
         String text = DaoConst.SQL_LOAD.replace(DaoConst.CODE_TABLE, this.name);
         SqlData sql = new SqlData(sqlName, text);
         sql.setSqlType(DaoConst.SQL_TYPE_EXISTS);
@@ -692,7 +695,14 @@ public class TableStruct {
                 String.format(DaoConst.CODE_WHERE_NOT_EQUALS_PARA, this.getKey().name)
         );
 
-        for (String fieldName : fields) {
+        for (String fieldName : mustField.getFields()) {
+            TableFieldVo field = this.getField(fieldName);
+            sql.addConst(field.inputName,
+                    String.format(DaoConst.CODE_WHERE_EQUALS_PARA, field.name)
+            );
+        }
+
+        for (String fieldName : allowNullField.getFields()) {
             TableFieldVo field = this.getField(fieldName);
             sql.addConst(field.inputName,
                     String.format(DaoConst.CODE_WHERE_EQUALS_NOT_EMPTY_PARA, field.name)