zoukankan html css js c++ java

jira ao UpgradeTask

插件发布到市场后，后续版本迭代的过程中，可能会对ao实体类的字段作添加或删除，或者要将某一字段的值映射解析到另一字段上。

本来这个工作，可以在插件启动的时候，在实现了com.atlassian.sal.api.lifecycle.LifecycleAware 接口的类onStart方法类完成。

但是历史版本更新了哪些字段不好维护，以前查看其它插件的代码时有看到版本更新任务的代码，但是因为实际工作中用的很少，就没去细看。

这几天查看atlassian的文档时，发现有一篇专门介绍如何处理upgradTask的文档。其实这篇文档是在一个系列中的，话说回来，atlassian插件开发的文档虽然挺全的，但是总体的文档结构还是有点乱的。

下文是对文档上的一些内容的截取

比如说我们之前有一个Todo类，它继承了Entity

 1 @Preload 
 2 public  interface  Todo  extend Entity { 
 3     void  setUserName （String  userName ）;
 4 
 5     String  getUserName （）;
 6 
 7     String  getDescription （）;
 8 
 9     void  setDescription （String  description ）;
10 
11     boolean  isComplete （）;
12 
13     void  setComplete （boolean  complete ）; 
14 }

Todo类中维护了一个userName字段，但是在后续的开发中，用户需要维护的信息很多，不止是用户名这么简单了。此时我们需要重新建一个User表，用来存放用户信息。

1 public interface User extends Entity
2 {
3     String getName();
4     void setName(String name);
5 }

Todo类也得做修改

 1 package com.atlassian.tutorial.ao.todo;
 2 
 3 import net.java.ao.Entity;
 4 import net.java.ao.Preload;
 5 import net.java.ao.schema.NotNull;
 6 
 7 @Preload
 8 public interface Todo extends Entity
 9 {
10     @NotNull
11     void setUser(User user);
12 
13     @NotNull
14     User getUser();
15 
16     String getDescription();
17 
18     void setDescription(String description);
19 
20     boolean isComplete();
21 
22     void setComplete(boolean complete);
23 }
24

之前service里的方法当然得修改，但这不是我们这里讨论的重点，接下来我们看，如何使用upgradetask更新数据库数据。

首先在ao包下面新建一个pacakge，名为upgrade.v2(官网上还建了v1包，但是那个升级改动较小，这里就不详述了)。

每次版本更新都要新建一个（v版本号）的包，包内存放需要更新的数据库实体类(从ao.entity包内复制过来，并做相应的改动。它不会在数据库内重新建一张表，只是用来记录更新信息)和更新任务类

 1 package com.atlassian.tutorial.ao.todo.upgrade.v2;
 2 
 3 import net.java.ao.Entity;
 4 import net.java.ao.Preload;
 5 // 保留了需要更新掉的字段user_name和需要新增的user_id字段（即getUser）
 6 @Preload
 7 public interface Todo extends Entity
 8 {
 9     void setUserName(String userName);
10 
11     String getUserName();
12 
13     void setUser(User user);
14 
15     User getUser();
16 
17     String getDescription();
18 
19     void setDescription(String description);
20 
21     boolean isComplete();
22 
23     void setComplete(boolean complete);
24 }

user表是新增的，没有改动，直接复制过来

接下来就是更新的代码类了

 1 package com.atlassian.tutorial.ao.todo.upgrade.v2; // (1) 引用upgrade.v2包下的类
 2 
 3 import com.atlassian.activeobjects.external.ActiveObjects;
 4 import com.atlassian.activeobjects.external.ActiveObjectsUpgradeTask;
 5 import com.atlassian.activeobjects.external.ModelVersion;
 6 import com.google.common.collect.ImmutableMap;
 7 import net.java.ao.Query;
 8 
 9 public final class TodoUpgradeTask002 implements ActiveObjectsUpgradeTask
10 {
11     @Override
12     public ModelVersion getModelVersion()
13     {
14         return ModelVersion.valueOf("2"); // (2) 版本设置为2
15     }
16 
17     @Override
18     public void upgrade(ModelVersion currentVersion, ActiveObjects ao)
19     {
20         ao.migrate(Todo.class, User.class); // (3) 声明需要操作的类
21 
22         Todo[] todos = ao.find(Todo.class); // (4) 实际升级，设置User对应的userName。
23         for (Todo todo : todos)
24         {
25             todo.setUser(getOrCreateUser(ao, todo.getUserName()));
26             todo.save();
27         }
28     }
29 
30     private User getOrCreateUser(ActiveObjects ao, String userName)
31     {
32         User[] users = ao.find(User.class, Query.select().where("NAME = ?", userName));
33         if (users.length == 0) {
34             return createUser(ao, userName);
35         } else if (users.length == 1) {
36             return users[0];
37         } else {
38             throw new IllegalStateException("There shouldn't be 2 users with the same username! " + userName);
39         }
40     }
41 
42     private User createUser(ActiveObjects ao, String userName)
43     {
44         return ao.create(User.class, ImmutableMap.<String, Object>of("NAME", userName));
45     }
46 }

最后，需要在atlassian-plugin.xml中配置

1  <ao key="ao-module">
2         <description>The module configuring the Active Objects service used by this plugin</description>
3         <entity>com.atlassian.tutorial.ao.todo.Todo</entity>
4         <entity>com.atlassian.tutorial.ao.todo.User</entity>
5         <upgradeTask>com.atlassian.tutorial.ao.todo.upgrade.v1.TodoUpgradeTask001</upgradeTask>
6         <upgradeTask>com.atlassian.tutorial.ao.todo.upgrade.v2.TodoUpgradeTask002</upgradeTask>
7     </ao>

执行，下面是官网给出的执行日志，

 1 [INFO] [talledLocalContainer]  INFO - assian.activeobjects.internal.ActiveObjectUpgradeManagerImpl - Starting upgrade of data model, current version is 1
 2 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - CREATE TABLE AO_3F7D93_USER (
 3 [INFO] [talledLocalContainer]     ID INTEGER GENERATED BY DEFAULT AS IDENTITY (START WITH 1) NOT NULL,
 4 [INFO] [talledLocalContainer]     NAME VARCHAR(255),
 5 [INFO] [talledLocalContainer]     PRIMARY KEY(ID)
 6 [INFO] [talledLocalContainer] )
 7 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - ALTER TABLE AO_3F7D93_TODO ADD COLUMN USER_ID INTEGER
 8 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - ALTER TABLE AO_3F7D93_TODO ADD CONSTRAINT fk_ao_3f7d93_todo_user_id FOREIGN KEY (USER_ID) REFERENCES AO_3F7D93_USER(ID)
 9 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - CREATE INDEX index_ao_3f7d93_todo_user_id ON AO_3F7D93_TODO(USER_ID)
10 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - SELECT * FROM AO_3F7D93_TODO
11 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - SELECT ID FROM AO_3F7D93_USER WHERE NAME = ?
12 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - INSERT INTO AO_3F7D93_USER (NAME) VALUES (?)
13 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - UPDATE AO_3F7D93_TODO SET USER_ID = ? WHERE ID = ?
14 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - SELECT ID FROM AO_3F7D93_USER WHERE NAME = ?
15 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - UPDATE AO_3F7D93_TODO SET USER_ID = ? WHERE ID = ?
16 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - SELECT ID FROM AO_3F7D93_USER WHERE NAME = ?
17 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - INSERT INTO AO_3F7D93_USER (NAME) VALUES (?)
18 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - UPDATE AO_3F7D93_TODO SET USER_ID = ? WHERE ID = ?
19 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - SELECT ID FROM AO_3F7D93_USER WHERE NAME = ?
20 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - UPDATE AO_3F7D93_TODO SET USER_ID = ? WHERE ID = ?
21 [INFO] [talledLocalContainer]  INFO - assian.activeobjects.internal.ActiveObjectUpgradeManagerImpl - Finished upgrading, model is up to date at version 2
22 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - ALTER TABLE AO_3F7D93_TODO DROP COLUMN USER_NAME
23 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - ALTER TABLE AO_3F7D93_TODO DROP CONSTRAINT fk_ao_3f7d93_todo_user_id
24 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - ALTER TABLE AO_3F7D93_TODO ALTER COLUMN USER_ID INTEGER NOT NULL
25 [INFO] [talledLocalContainer] DEBUG -                                              net.java.ao.sql - ALTER TABLE AO_3F7D93_TODO ADD CONSTRAINT fk_ao_3f7d93_todo_user_id FOREIGN KEY (USER_ID) REFERENCES AO_3F7D93_USER(ID)

最后几行可以看出，在完成升级任务之后，数据库的表结构也变了，user_name字段被移除

查看全文

相关阅读:
Flink 读取 Kafka 数据（极简版）
自动化测试模型
 C语言字符串处理库函数大全（转）
c语言笔记
 c语言的自动类型转换（转）
itest(爱测试)开源接口测试&敏捷测试管理平台8.1.0发布
 itest(爱测试)开源接口测试&敏捷测试&极简项目管理 8.0.0 发布，测试重大升级
 工控机折腾小记
 linux
华为交换机服务端策略路由配置

原文地址：https://www.cnblogs.com/blog-cq/p/10423815.html