From c68faf5914955236416e1f11248077c71927661c Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Wed, 22 Oct 2025 15:36:21 +0800
Subject: [PATCH] =?UTF-8?q?or=E6=9D=A1=E4=BB=B6sql=20=E7=A4=BA=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/czg/Main.java           | 64 +++++++++++++++++--
 1 file changed, 57 insertions(+), 7 deletions(-)

diff --git a/cash-service/code-generator/src/main/java/com/czg/Main.java b/cash-service/code-generator/src/main/java/com/czg/Main.java
index aca2b052..fc1ff05c 100644
--- a/cash-service/code-generator/src/main/java/com/czg/Main.java
+++ b/cash-service/code-generator/src/main/java/com/czg/Main.java
@@ -1,7 +1,9 @@
 package com.czg;
 
+import com.czg.market.entity.MkLimitTimeDiscount;
 import com.mybatisflex.codegen.Generator;
 import com.mybatisflex.codegen.config.*;
+import com.mybatisflex.core.query.QueryWrapper;
 import com.mybatisflex.core.service.IService;
 import com.mybatisflex.spring.service.impl.ServiceImpl;
 import com.zaxxer.hikari.HikariDataSource;
@@ -10,7 +12,7 @@ import com.zaxxer.hikari.HikariDataSource;
  * @author ww
  */
 public class Main {
-//    private final static String BASE_URL = "rm-bp1kn7h89nz62cno1ro.mysql.rds.aliyuncs.com";
+    //    private final static String BASE_URL = "rm-bp1kn7h89nz62cno1ro.mysql.rds.aliyuncs.com";
     private final static String BASE_URL = "192.168.1.42";
     private final static String PORT = "3306";
     private final static String USERNAME = "root";
@@ -20,19 +22,24 @@ public class Main {
     static String basePackage = "com.czg.";
 
     public static void main(String[] args) {
+        //or条件sql写法示例
+//        orSqlTest();
 
-        //  tableName   指定需要生成的表
 
 //        String packageName = "system";
 //        String packageName = "account";
 //        String packageName = "product";
         String packageName = "market";
-
-        String tableName = "mk_drainage_config";
-        String author = "zs";
+        //  tableName   指定需要生成的表
+        String tableName = "mk_product_smart_suggest";
+        String author = "ww";
         //是否生成DTO实体 默认生成
-        boolean isGenerateDto = false;
+        boolean isGenerateDto = true;
 
+        initTableEntity(packageName, tableName, author, isGenerateDto);
+    }
+
+    public static void initTableEntity(String packageName, String tableName, String author, boolean isGenerateDto) {
         //配置数据源
         HikariDataSource dataSource = new HikariDataSource();
         dataSource.setJdbcUrl("jdbc:mysql://" + BASE_URL + ":" + PORT + "/" + DATABASE);
@@ -55,7 +62,7 @@ public class Main {
         serviceGenerator.generate();
 
         //默认生成全参数DTO
-        if(isGenerateDto){
+        if (isGenerateDto) {
             GlobalConfig dtoConfig = createDtoGlobalConfig(currentWorkingDirectory + "/cash-common/cash-common-service",
                     basePackage + packageName, "tb", tableName);
             Generator dtoGenerator = new Generator(dataSource, dtoConfig);
@@ -64,6 +71,49 @@ public class Main {
         }
     }
 
+
+    public static void orSqlTest() {
+        QueryWrapper queryWrapper1 = new QueryWrapper();
+        queryWrapper1.eq(MkLimitTimeDiscount::getId, 2)
+                .or(MkLimitTimeDiscount::getShopId)
+                .gt(25);
+        System.out.println(queryWrapper1.toSQL());
+        System.out.println();
+
+        QueryWrapper queryWrapper3 = new QueryWrapper();
+        queryWrapper3.eq(MkLimitTimeDiscount::getTitle, "王五")
+                .or(wrapper -> {
+                            wrapper.lt(MkLimitTimeDiscount::getShopId, 20)
+                                    .gt(MkLimitTimeDiscount::getId, 100);
+                        }
+                );
+        System.out.println(queryWrapper3.toSQL());
+        System.out.println();
+
+        QueryWrapper queryWrapper4 = new QueryWrapper();
+        queryWrapper4.eq(MkLimitTimeDiscount::getTitle, "李四")
+                .or("id BETWEEN ? AND ?", 20, 40);
+        System.out.println(queryWrapper4.toSQL());
+        System.out.println();
+        QueryWrapper queryWrapper = new QueryWrapper();
+        queryWrapper.eq(MkLimitTimeDiscount::getShopId, 2)
+                .eq(MkLimitTimeDiscount::getIsDel, 0)
+                .orderBy(MkLimitTimeDiscount::getSort).desc()
+                .orderBy(MkLimitTimeDiscount::getUpdateTime).desc();
+
+        queryWrapper.and(q -> {
+            q.eq(MkLimitTimeDiscount::getUseShopType, "all").or(q1 -> {
+                q1.eq(MkLimitTimeDiscount::getUseShopType, "only").eq(MkLimitTimeDiscount::getShopId, 3);
+            }).or(q2 -> {
+                q2.eq(MkLimitTimeDiscount::getUseShopType, "custom").and(q3 -> {
+                    q3.eq(MkLimitTimeDiscount::getShopId, 3).or("FIND_IN_SET( " + 3 + ", use_shops ) > 0");
+                });
+            });
+        });
+
+        System.out.println(queryWrapper.toSQL());
+    }
+
     public static GlobalConfig createGlobalConfigUseStyle(String projectPath, String packageName, String tablePrefix, String... tableNames) {
         //创建配置内容
         GlobalConfig globalConfig = new GlobalConfig();