文档章节

APDPlat如何自动建库建表并初始化数据?

杨尚川
 杨尚川
发布于 2014/02/08 10:18
字数 1303
阅读 360
收藏 1

APDPlat共支持10种数据库:DB2、DERBY、H2、HSQL、INFORMIX、MYSQL、ORACLE、POSTGRESQL、SQL_SERVER、SYBASE。

 

数据库的默认配置信息在文件APDPlat_Core/src/main/resources/org/apdplat/db.properties中定义,用户可以根据自己的选择,在APDPlat_Web/src/main/resources/db.local.properties配置文件中覆盖默认配置。

 

1、如何指定使用哪一种数据库呢?

 

jpa.database=MYSQL

 

 

jpa.database配置项的值可为上述10种数据库之一,10种数据库的JDBC驱动已经集成到APDPlat中,其中5种定义到maven配置文件APDPlat_Web/pom.xml的依赖中,其余5种放置在APDPlat_Web/src/main/webapp/WEB-INF/lib目录中。

 

2、如何配置数据库连接信息呢? 

 

#mysql
db.driver=com.mysql.jdbc.Driver
db.url=jdbc:mysql://localhost:3306/${module.short.name}?useUnicode=true&characterEncoding=UTF-8&createDatabaseIfNotExist=true&autoReconnect=true
db.username=root
db.password=root
jpa.database=MYSQL
db.backup.command=mysqldump  -u${db.username} -p${db.password} ${module.short.name}
db.restore.command=mysql -u${db.username} -p${db.password} ${module.short.name}

db.forlog.driver=com.mysql.jdbc.Driver
db.forlog.url=jdbc:mysql://localhost:3306/${module.short.name}_for_log?useUnicode=true&characterEncoding=UTF-8&createDatabaseIfNotExist=true&autoReconnect=true
db.forlog.username=root
db.forlog.password=root
jpa.forlog.database=MYSQL

  

 

在文件APDPlat_Core/src/main/resources/org/apdplat/db.properties中已经预先定义了10种数据库的连接信息,用户可在此基础上修改成适合自己的连接信息,然后放置到配置文件APDPlat_Web/src/main/resources/db.local.properties中覆盖默认配置。

 

对于MYSQL数据库来说,因为指定了createDatabaseIfNotExist=true选项,所以会自动建库ORACLESQL_SERVER需要手动建库。其他数据库请参考相关的JDBC编程指南文档,总之,在这里只需要提供标准的JDBC编程所需的信息:driver、url、username、password。

 

3、表是怎么建的呢?

 

表是自动建的,不需要手动执行数据库DDL,是由如下配置指定的:

 

jpa.generateDdl=true

 

 

在文件APDPlat_Core/src/main/resources/org/apdplat/db.properties中还定义了数据库连接池以及数据库缓存的配置信息,详情参考配置文件。

 

4、初始数据是怎么导入的?

 

初始数据是在系统启动的时候自动导入的,不需要手工执行SQL脚本导入数据。RegisterService抽象类为数据导入提供了支持,在Spring容器初始完毕后就会检查是否需要导入数据,只有在表为空的情况下才会执行导入,也就是说能够保证只会导入一次,执行导入调用的是抽象方法registe,需要子类来实现,这是一个典型的"模板方法"设计模式:

 

public abstract class RegisterService<T extends Model> implements ApplicationListener {
    protected final APDPlatLogger LOG = APDPlatLoggerFactory.getAPDPlatLogger(getClass());
    
    @Resource(name="serviceFacade")
    protected ServiceFacade serviceFacade;
    @Resource(name="entityManagerFactory")
    protected EntityManagerFactory entityManagerFactory;
    
    protected Class<T> modelClass;
    @Override
    public void onApplicationEvent(ApplicationEvent event){
        if(event instanceof ContextRefreshedEvent){
            this.modelClass = ReflectionUtils.getSuperClassGenricType(getClass());
            LOG.info("spring容器初始化完成, 开始检查 "+ModelMetaData.getMetaData(this.modelClass.getSimpleName()) +" 是否需要初始化数据");
            if(shouldRegister()){
                LOG.info("需要初始化 "+ModelMetaData.getMetaData(this.modelClass.getSimpleName()));
                openEntityManager();
                registe();
                closeEntityManager();
                registeSuccess();
            }else{
                LOG.info("不需要初始化 "+ModelMetaData.getMetaData(this.modelClass.getSimpleName()));
            }
        }
    }
    private void openEntityManager(){        
        EntityManager em = entityManagerFactory.createEntityManager();
        TransactionSynchronizationManager.bindResource(entityManagerFactory, new EntityManagerHolder(em));
        LOG.info("打开实体管理器");
    }
    private void closeEntityManager(){
        EntityManagerHolder emHolder = (EntityManagerHolder)TransactionSynchronizationManager.unbindResource(entityManagerFactory);
        LOG.info("关闭实体管理器");
        EntityManagerFactoryUtils.closeEntityManager(emHolder.getEntityManager());
    }
    protected void registeSuccess(){
        
    }
    protected List<T> getRegisteData(){
        return null;
    }
    protected abstract void registe();

    protected boolean shouldRegister() {
        Page<T> page=serviceFacade.query(modelClass);
        if(page.getTotalRecords()==0) {
            return true;
        }
        return false;
    }
}

 

 

下面我们看一个导入用户数据(至少数据库中有用户数据才能登陆吧)的例子,这里RegisteUser 实现了抽象类RegisterService的抽象方法registe,执行真正的数据导入操作。从这里我们可以看到,用户数据是从类路径下的/data/user.xml文件中获得的。事实上,这个文件是在APDPlat启动的时候从APDPlat_Core-X.X.jar中提取出来的。这里使用了Page的newInstance静态方法把一个XML数据文件转换为了JAVA页面对象。之后设置用户数据的依赖,即用户所属的组织架构和角色,注意这里的导入是有先后顺序的,需要保证顺序。

 

/**
 * 注册用户数据,这里需要注意的是:
 * 因为User有一个Org字段和一个Role列表(protected Org org; protected List<Role> roles = new ArrayList<>();)
 * 所以要先注册了Org和Role之后才能注册用户
 * 但是RegisteUser、RegisteOrg以及RegisteRole都继承自RegisterService
 * 都实现了Spring的ApplicationListener接口
 * 那么Spring会先调用谁呢?
 * 为了保证先注册Org和Role
 * RegisteUser类用@Resource注解注入了RegisteOrg和RegisteRole,分别用来获取Org和Role
 * Spring保证会在装配完成RegisteOrg和RegisteRole之后才装配RegisteUser
 * 而装配的先后顺序也就是Spring调用实现ApplicationListener接口的Bean的顺序
 * 因此,这里的注册数据依赖问题就完美地解决了
 * @author 杨尚川
 */
@Service
public class RegisteUser extends RegisterService<User>{
    @Resource(name="registeOrg")
    protected RegisteOrg registeOrg;
    @Resource(name="registeRole")
    protected RegisteRole registeRole;

    @Override
    protected void registe() {
        String xml="/data/user.xml";
        LOG.info("注册【"+xml+"】文件");
        LOG.info("验证【"+xml+"】文件");
        boolean pass=XMLUtils.validateXML(xml);
        if(!pass){
            LOG.info("验证没有通过,请参考dtd文件");
            return ;
        }
        LOG.info("验证通过");
        Page<User> page=Page.newInstance(User.class, RegisteUser.class.getResourceAsStream(xml));
        if(page!=null){
            for(User user : page.getModels()){
                user.setPassword(PasswordEncoder.encode(user.getPassword(), user));
                user.setOrg(registeOrg.getRegisteData().get(0));
                user.addRole(registeRole.getRegisteData().get(0).getChild().get(0));
                serviceFacade.create(user);
            }
        }
    }
}

 

 

最后看一下数据文件/data/user.xml的内容:

 

 

 

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE page SYSTEM  "user.dtd">
<!--
        用户
-->
<page xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
    <models>
        <model xsi:type="User" username="admin" password="admin" enabled="true" des="超级管理员"/>
    </models>
</page>

 

 

 APDPlat托管在Github

 

© 著作权归作者所有

杨尚川

杨尚川

粉丝 1103
博文 220
码字总数 1624053
作品 12
东城
架构师
私信 提问
APDPlat的系统启动和关闭流程剖析

APDPlat接管了Spring的启动关闭权,为各种运行其上的开源框架和类库的无缝集成提供了支持。 当然,大家都知道,一个JAVA EE Web应用的入口点是web.xml,APDPlat当然也不例外,我们看看APDPl...

杨尚川
2014/02/03
414
0
基于word分词提供的文本相似度算法来实现通用的网页相似度检测

实现代码:基于word分词提供的文本相似度算法来实现通用的网页相似度检测 运行结果: 检查的博文数:128 1、检查博文:192本软件著作用词分析(五)用词最复杂99级,相似度分值:Simple=0.96...

杨尚川
2015/05/28
1K
0
APDPlat拓展搜索之集成Solr

APDPlat充分利用Compass的OSEM和ORM integration特性,提供了简单易用且功能强大的内置搜索特性。 APDPlat的内置搜索,在设计简洁优雅的同时,还具备了强大的实时搜索能力,用户只需用注解的...

杨尚川
2014/02/01
662
0
应用级产品开发平台 - APDPlat

APDPlat快速体验 APDPlat入门指南 APDPlat专题文章 APDPlat是Application Product Development Platform(应用级产品开发平台)的缩写。 APDPlat提供了应用容器、多模块架构、代码生成、安装...

杨尚川
2012/10/30
6.7K
0
APDPlat拓展搜索之集成ElasticSearch

APDPlat充分利用Compass的OSEM和ORM integration特性,提供了简单易用且功能强大的内置搜索特性。 APDPlat的内置搜索,在设计简洁优雅的同时,还具备了强大的实时搜索能力,用户只需用注解的...

杨尚川
2014/02/01
292
2

没有更多内容

加载失败,请刷新页面

加载更多

Android面试常客之Handler全解

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。 本文链接:https://blog.csdn.net/fnhfire_7030/article/details/79518819 前言:又到了一年...

shzwork
4分钟前
0
0
position sticky 定位

本文转载于:专业的前端网站➫position sticky 定位 1、兼容性 https://caniuse.com/#search=sticky chrome、ios和firefox兼容性良好。 2、使用场景 sticky:粘性。粘性布局。 在屏幕范围内时...

前端老手
11分钟前
1
0
CentOS 7 yum 安装 PHP7.3 教程

参考:https://www.mf8.biz/centos-rhel-install-php7-3/ 1、首先安装 EPEL 源: yum install epel-release 安装 REMI 源: yum install http://rpms.remirepo.net/enterprise/remi-release......

dragon_tech
25分钟前
1
0
Linux物理网卡聚合及桥接

Linux内部实现的bridge可以把一台机器上的多张网卡桥接起来,从而把自己作为一台交换机。同时,LInux bridge还支持虚拟端口,即桥接的不一定都是物理网卡接口,还可以是虚拟接口。目前主要表...

xiangyunyan
26分钟前
1
0
一起来学Java8(一)——函数式编程

在这篇文章中,我们将了解到在Java8下如何进行函数式编程。 函数式编程 所谓的函数式编程就是把函数名字当做值进行传递,然后接收方拿到这个函数名进行调用。 首先来看下JavaScript如何进行函...

猿敲月下码
57分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部