Java 新的生态，更小、更快、更简单！

# activerecord-solon-plugin #### 介绍 此说明文档中的示例及源码来自于专有Demo：https://gitee.com/gollyhu/activerecord-solon-plugin-demo #### 使用说明 1. 配置示例 ```yaml demo.db1: schema: rock jdbcUrl: jdbc:mysql://localhost:3306/jfinal_demo?useSSL=false driverClassName: com.mysql.jdbc.Driver username: root password: 123456 demo.db2: schema: rock jdbcUrl: jdbc:mysql://localhost:3306/jfinal_demo?useSSL=false driverClassName: com.mysql.jdbc.Driver username: root password: 123456 ``` 2. 启动示例 ``` java /** * 启动应用 */ public class DemoApp { public static void main(String[] args) { Solon.start(DemoApp.class, args, app -> { app.onEvent(ActiveRecordPlugin.class, arp -> { if (Solon.cfg().isDebugMode() || Solon.cfg().isFilesMode()) { arp.setDevMode(true); // 启用开发模式 arp.setShowSql(true); // 启用SQL输出 } }); }); } } ``` 3. 数据源配置示例 ``` java /** * 配置数据源 */ @Configuration public class Config { @Bean(name="db1", typed=true) // typed=true 为默认数据源 public DataSource db1(@Inject("${demo.db1}") HikariDataSource dataSource) { return dataSource; } @Bean("db2") // 指定ActiveRecord数据源名称为db2 public DataSource db2(@Inject("${demo.db2}") HikariDataSource dataSource) { return dataSource; } } ``` 4. 应用示例 ```java @Controller @Mapping("/blog") public class BlogController { @Inject BlogService blogService; @Mapping("/add") public ModelAndView add(Context ctx) { return new ModelAndView("/blog/add.html"); } @Mapping("/delete/{id}") public void delete(Context ctx, Integer id) { this.blogService.deleteById(id); ctx.redirect("/blog"); } @Mapping("/edit/{id}") public ModelAndView edit(Context ctx, Integer id) { ModelAndView mav = new ModelAndView("/blog/edit.html"); mav.put("blog", this.blogService.findById(id)); return mav; } @Mapping public ModelAndView index(Context ctx) { return this.index(ctx, 1); } @Mapping("/{pageNumber}") public ModelAndView index(Context ctx, Integer pageNumber) { ModelAndView mav= new ModelAndView("/blog/blog.html"); mav.put("blogPage", this.blogService.paginate(pageNumber, 10)); return mav; } /** * save 与 update 的业务逻辑在实际应用中也应该放在 serivce 之中， * 并要对数据进正确性进行验证，在此仅为了偷懒 */ @NotEmpty({"title", "content"}) @Mapping("/save") public void save(Context ctx, @Validated Blog blog) { this.blogService.save(blog); ctx.redirect("/blog"); } /** * save 与 update 的业务逻辑在实际应用中也应该放在 serivce 之中， * 并要对数据进正确性进行验证，在此仅为了偷懒 */ @NotEmpty({"id", "title", "content"}) @Mapping("/update") public void update(Context ctx, @Validated Blog blog) { this.blogService.update(blog); ctx.redirect("/blog"); } } ``` #### 代码生成 1. 代码生成器 ```java /** * 代码生成器 */ public class _Generator { public static void main(String[] args) { // 获取数据源 DataSource ds1 = getDataSource1(); DataSource ds2 = getDataSource2(); System.out.println("Start generate...\n"); // 默认数据源 SolonGenerator generator = new SolonGenerator(ds1, "cn.hg.solon.plugin.activerecord.demo.common"); // 排除表 generator.addBlacklist("blog2"); // 指定自定义Model基类 generator.setBaseModelClassName(BaseModel.class.getName()); // 生成 generator.generate(); // ds2数据源 SolonGenerator generator2 = new SolonGenerator(ds2, "cn.hg.solon.plugin.activerecord.demo.common"); // 排除表 generator2.addBlacklist("blog"); // 非默认数据一定要指定数据源Bean名称 generator2.setDataSourceBeanName("db2"); // 指定自定义Model基类 generator2.setBaseModelClassName(BaseModel.class.getName()); // 生成 generator2.generate(); System.out.println("\nFinished generate."); } private static DataSource getDataSource1() { HikariCpPlugin plugin = new HikariCpPlugin("jdbc:mysql://localhost/jfinal_demo?useSSL=false", "root", "123456"); plugin.start(); return plugin.getDataSource(); } private static DataSource getDataSource2() { HikariCpPlugin plugin = new HikariCpPlugin("jdbc:mysql://localhost/jfinal_demo?useSSL=false", "root", "123456"); plugin.start(); return plugin.getDataSource(); } } ``` 2. 代码结构   3. 代码示例 - Mapper ```java @Namespace("BlogMapper") public interface BlogMapper { ...... // isUpdate = true 表示接口为非查询接口 @Sql(value = "{DELETE FROM `blog` WHERE `id` = #para(id)}", isUpdate = true) long deleteById(Object id); ...... @Sql("{ SELECT * FROM `blog` }") List<Blog> findAll(); @Sql("findByModel") List<Blog> findBy(Blog model); @Sql("findByMap") List<Blog> findBy(Map<String, ?> map); @Sql("findByModel") List<Blog> findBy(Blog model, String orderColumn, String orderDirection); @Sql("findByMap") List<Blog> findBy(Map<String, ?> map, String orderColumn, String orderDirection); ...... } @Namespace("Blog2Mapper") public interface Blog2Mapper { ...... // isUpdate = true 表示接口为非查询接口 @Sql(value = "{DELETE FROM `blog2` WHERE `id` = #para(id)}", isUpdate = true) long deleteById(Object id); ...... @Sql("{ SELECT * FROM `blog2` }") List<Blog2> findAll(); @Sql("findByModel") List<Blog2> findBy(Blog2 model); @Sql("findByMap") List<Blog2> findBy(Map<String, ?> map); @Sql("findByModel") List<Blog2> findBy(Blog2 model, String orderColumn, String orderDirection); @Sql("findByMap") List<Blog2> findBy(Map<String, ?> map, String orderColumn, String orderDirection); ...... } ``` - BaseModel ```java public abstract class BaseBlog<M extends BaseBlog<M>> extends Model<M> implements IBean { ...... } public abstract class BaseBlog2<M extends BaseBlog2<M>> extends Model<M> implements IBean { ...... } ``` - Model ```java @Db(DbKit.MAIN_CONFIG_NAME) @Table(name = "blog", primaryKey = "id") public class Blog extends BaseBlog<Blog> { public static final Blog DAO = new Blog().dao(); } @Db("db2") // 生成此对象时指定了数据源名称为"db2" @Table(name = "blog2", primaryKey = "id") public class Blog2 extends BaseBlog2<Blog2> { public static final Blog2 DAO = new Blog2().dao(); } ``` - SQL ```sql BlogMapper.sql 文件 #namespace("BlogMapper") #sql("countBy") ### 统计满足条件的记录数 SELECT COUNT(*) FROM `blog` #@whereFor() #end #sql("de