// SELECT * FROM `user` WHERE `id` = ? LIMIT 1
User user = UserQueryPro.selectByPrimaryKey(1);

// SELECT * FROM `user` WHERE `user`.`id` = ?
List<User> users = UserQueryPro.selectBy().username().is().equalsTo("hello").run();

// SELECT * FROM `user` WHERE `user`.`id` = ? OR `user`.`age` = ?
List<User> users2 = UserQueryPro
        .selectBy().id().eq(1) // is 是可选的
        .or().age().not().in(10, 11)
        .run();

// 使用主键查询
// SELECT * FROM `user` WHERE `id` = ? LIMIT 1
User user0 = UserQueryPro.selectByPrimaryKey(1);

// 使用某个字段查询
// !!! 所有的 is 是可以省略的，但有时候加着更好看
// SELECT * FROM `user` WHERE `user`.`id` = ?
List<User> users1_1 = UserQueryPro.selectBy().id().is().equalsTo(1).run();
List<User> users1_2 = UserQueryPro.selectBy().id().eq(1).run();
List<User> users1_3 = UserQueryPro.selectBy().id(1).run();

// 使用in, between, lessThan, lessThanOrEqual, graterThan, graterThanOrEqual等查询
// SELECT * FROM `user` WHERE `user`.`name` in (?, ?)
List<User> users2_1 = UserQueryPro.selectBy().name().in("hb", "herb").run();
List<User> users2_2 = UserQueryPro.selectBy().name("hb", "herb").run();
// SELECT * FROM `user` WHERE `user`.`age` between (?, ?)
List<User> users2_3 = UserQueryPro.selectBy().age().between(18, 20).run();
// SELECT * FROM `user` WHERE `user`.`age` < ?
List<User> users2_5 = UserQueryPro.selectBy().age().lessThan(18).run();

// 使用and查询
// !!! and是可以省略的，但有时候加着更好看
// SELECT * FROM `user` WHERE `user`.`name` = ? AND `user`.`age` = ?
List<User> usersRun3 = UserQueryPro
        .selectBy().name().is().equalsTo("hb")
        .and().age().is().equalsTo(18)
        .run();

// 使用or查询
// SELECT * FROM `user` WHERE `user`.`id` = ? OR `user`.`age` = ?
List<User> usersRun5_1 = UserQueryPro.selectBy().id().is().equalsTo(1).or().age().equalsTo(10).run();
// SELECT * FROM `user` WHERE `user`.`id` = ? OR (`user`.`age` = ? AND `user`.`name` like ?)
List<User> usersRun5_2 = UserQueryPro
        .selectBy().id().is().equalsTo(1)
        .or((it) -> it.age().equalsTo(18).and().name().like("%rb%"))
        .run();
// SELECT * FROM `user` WHERE `user`.`id` = ? OR (`user`.`age` = ? AND `user`.`name` like ?)
List<User> usersRun5_3 = UserQueryPro
        .selectBy().id().is().equalsTo(1)
        .or().parLeft().age().equalsTo(18).and().name().like("%rb%").parRight()
        .run();

// 使用not查询
// SELECT * FROM `user` WHERE `user`.`id` <> ?
List<User> usersRun6_1 = UserQueryPro.selectBy().id().is().not().equalsTo(2).run();
// SELECT * FROM `user` WHERE `user`.`id` not in (?, ?)
List<User> usersRun6_2 = UserQueryPro.selectBy().id().is().not().in(1, 2).run();
// SELECT * FROM `user` WHERE `user`.`id` not between (?, ?)
List<User> usersRun6_2 = UserQueryPro.selectBy().id().not().between(1, 2).run();
// SELECT * FROM `user` WHERE `user`.`name` not like ?
List<User> usersRun6_2 = UserQueryPro.selectBy().name().not().like("%H%").run();

// 忽略大小写
// SELECT * FROM `user` WHERE UPPER(`user`.`name`) like UPPER(?)
List<User> users7 = UserQueryPro.selectBy().name().ignoreCase().like("%H%").run();

// is null 查询
// SELECT * FROM `user` WHERE `user`.`age` is null
List<User> users8_1 = UserQueryPro.selectBy().age().is().nul().run();
// SELECT * FROM `user` WHERE `user`.`age` is not null
List<User> users8_2 = UserQueryPro.selectBy().age().is().not().nul().run();

// like查询
// SELECT * FROM `user` WHERE `user`.`name` like ? ORDER BY `user`.`id` DESC
List<User> users9 = UserQueryPro.selectBy().name().like("%h%").orderBy().id().desc().run();

// 排序
// SELECT * FROM `user` ORDER BY `user`.`id` DESC
List<User> users10_1 = UserQueryPro.orderBy().id().desc().run();
// SELECT * FROM `user` ORDER BY `user`.`age` ASC, `user`.`id` DESC
List<User> users10_2 = UserQueryPro.orderBy().age().asc().id().desc().run();

// 限制返回结果数量
// SELECT * FROM `user` ORDER BY `user`.`age` DESC, `user`.`id` ASC LIMIT 1
List<User> users11_1 = UserQueryPro.orderBy().age().desc().id().asc().limit(1).run();
// SELECT * FROM `user` LIMIT 1
User user11_2 = UserQueryPro.selectBy().runLimit1();

// 只需要返回部分字段
// SELECT `setting`.`id` FROM `setting` WHERE `setting`.`id` = ?
List<Long> ids12_1 = SettingQueryPro.selectBy().id().equalsTo(1).columnLimiter().id();
// SELECT `user`.`id`, `user`.`age` FROM `user` WHERE `user`.`id` = ?
List<User> users12_2 = UserQueryPro.selectBy().id().equalsTo(1).columnsLimiter().id().age().run();
// SELECT `user`.`id`, `user`.`name` FROM `user` ORDER BY `user`.`age` DESC, `user`.`id` DESC LIMIT 1
List<User> usersRun14 = UserQueryPro
        .orderBy().age().desc().id().desc().limit(1)
        .columnsLimiter().id().name()
        .run();

// take方法（方便写if等条件)
// SELECT * FROM `user` WHERE `user`.`id` = ? AND `user`.`name` = ?
List<User> usersRun15 = UserQueryPro
        .selectBy().id().equalsTo(1)
        .take(it -> True ? it.name().equalsTo("hb") : it.name().equalsTo("hb2"))
        .run();

// 自定义sql查询

UserQueryPro.insert(...); // 参数支持 User, Map, Collection<User>, vararg User

UserQueryPro.updateSet(new User(19)).where.id.equalsTo(1).run()
UserQueryPro.updateSet().id(5).age(NULL).run()

// 逻辑删除默认启用，当存在deleted字段时，自动使用deleted字段进行逻辑删除
// UPDATE `setting` SET `deleted` = ? WHERE `setting`.`id` = ?
SettingQueryPro.deleteBy().id().is().equalsTo(1).run()

// SELECT * FROM `setting` WHERE  ( `setting`.`id` = ? OR `setting`.`kee` = ? )  AND `setting`.`deleted` = ? LIMIT 1
SettingQueryPro.selectBy().id().equalsTo(1).or().kee().equalsTo("lang").runLimit1()

QueryProSql.create().query()
QueryProSql.create().update()
QueryProSql.create().exec()

QueryProTransaction.use(() -> {
    // 业务代码
    return null;
})

DruidDataSource dataSource = new DruidDataSource();
dataSource.setUrl(url);
dataSource.setUsername(username);
dataSource.setPassword(password);
dataSource.setDriverClassName(drive);

// 针对本次请求，临时切换数据源
QueryPro.request.dataSource(dataSource)
        
// 针对某段查询，临时切换数据源
QueryProConfig.context.use((config) -> {
    config.dataSource(dataSource);

    User user = UserQueryPro.selectBy().name().equalsTo("username").runLimit1();
    List<Setting> themes = SettingQueryPro.selectBy().kee().equalsTo("theme").run();
});

// 针对某次查询，临时切换数据源
UserQueryPro.dataSource(dataSource).selectBy().name().equalsTo("username").run();

// 关闭逻辑删除
QueryProConfig.global.logicDelete(false); 
// 更改逻辑删除的字段，逻辑删除默认使用deleted字段，默认使用true代表逻辑已删除，false代表逻辑未删除
QueryProConfig.global.logicDelete(true, "removed", "Y", "N");

QueryProConfig.global
    .printLog(true) // 打印sql日志，默认开启
    .beautifySql(true) // 美化sql(加入空格，换行等)，默认开启
    .printCallByInfo(true) // 打印调用QueryPro所在的代码行，默认开启
    .printResult(true); // 打印返回结果，默认开启


// 会在INFO级别关闭日志的打印，但是DEBUG级别还是会打印
QueryProConfig.global.printLog(false)
// 关闭所有级别的日志打印
QueryProConfig.global.printLog(false, LogLevel.DEBUG)

QueryProConfig.global.shouldIgnoreFields().add("serialVersionUID");

QueryProConfig.global.setQueryStructureResolver(new JdbcQSR());

// 如果没有指定返回结果的类型，将id或_id结尾的无符号BIGINT类型转为Long。(这是默认行为，无需额外配置)
QueryProConfig.global.dbColumnInfoToJavaType().put(
        (columnInfo) -> {
            if (columnInfo.getType().startsWith("BIGINT")) { // 以BIGINT开头，包括了BIGINT_UNSIGNED
                String label = columnInfo.getLabel();
                if (label.equals("id") || label.endsWith("_id")) { // 字段名为id或者以_id结尾的
                    return true;
                }
            }
            return false;
        },
        Long.class // 转为Long类型
);

// 例如，这两个ResultSetParser一个简单一个略复杂，都已经内置在了`QueryPro`中
QueryProConfig.global
        .addResultSetParser(
            LocalDateTime.class,
            (resultSet, columIndex) -> resultSet.getTimestamp(columIndex).toLocalDateTime()
        )
        .addResultSetParserEx((resultSet, targetClass, columnIndex) -> { // 当需要同时支持多种返回类型时，可以使用addResultSetParserEx
            if (!targetClass.isEnum()) {
                return Optional.empty();
            }
            return Optional.of(Enum.valueOf((Class) targetClass, resultSet.getString(columnIndex)));
        });

QueryProConfig.global
        .lifecycle()
        .beforeInsert(
            builder -> builder
                .addField("deleted", Boolean.class, () -> false)
                .addField("create_time", Date.class, Date::new)
                .addField("create_by", String.class, XX::getCurrentUser)
        )
        .beforeUpdate(
            builder -> builder
                .overrideField("update_time", Date.class, Date::new)
                .overrideField("update_by", String.class, XX::getCurrentUser)
        );

public class ResultSetWalkerTest {

    private static class ResultSetWalker implements JdbcQSR.IResultSetWalker {
        final private List<String> columnNames = new ArrayList<>();

        @Override
        public void walk(@NotNull ResultSet rs) throws Exception {
            final ResultSetMetaData metaData = rs.getMetaData();
            final int columnCount = metaData.getColumnCount();
            for (int i = 1; i <= columnCount; i++) {
                final String columnLabel = metaData.getColumnLabel(i);
                columnNames.add(columnLabel);
            }
        }
    }

    @Test
    public void test() { QueryProConfig.context.use(conf -> {
        // 测试用例中，需要初始化QueryPro
        initLogger();
        conf.dataSource(getDataSource());

        // 提供一个实现了JdbcQSR.IResultSetWalker的类
        final ResultSetWalker walker = QueryProSql.create("select * from user left join setting on user.id = setting.user_id").queryOne(ResultSetWalker.class);
        assert walker != null;
        System.out.println(walker.columnNames);
    });}

}