Add ItemChangeSet Integration Test

apollo-adminservice/src/main/java/com/ctrip/apollo/adminservice/controller/ItemSetController.java

@@ -3,7 +3,6 @@ package com.ctrip.apollo.adminservice.controller;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
-import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
@@ -19,9 +18,8 @@ public class ItemSetController {
   private ItemSetService itemSetService;
 
   @RequestMapping(path = "/apps/{appId}/clusters/{clusterName}/namespaces/{namespaceName}/itemset", method = RequestMethod.POST)
-  public ResponseEntity<Void> create(@PathVariable String appId, @PathVariable String clusterName,
-                                     @PathVariable String namespaceName, @RequestBody ItemChangeSets changeSet) {
-    itemSetService.updateSet(appId, clusterName, namespaceName, changeSet);
+  public ResponseEntity<Void> create(@RequestBody ItemChangeSets changeSet) {
+    itemSetService.updateSet(changeSet);
     return ResponseEntity.status(HttpStatus.OK).build();
   }
 }

apollo-adminservice/src/test/java/com/ctrip/apollo/adminservice/controller/AbstractControllerTest.java

+package com.ctrip.apollo.adminservice.controller;
+
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.test.SpringApplicationConfiguration;
+import org.springframework.boot.test.TestRestTemplate;
+import org.springframework.boot.test.WebIntegrationTest;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.web.client.RestTemplate;
+
+import com.ctrip.apollo.AdminServiceTestConfiguration;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringApplicationConfiguration(classes = AdminServiceTestConfiguration.class)
+@WebIntegrationTest(randomPort = true)
+public abstract class AbstractControllerTest {
+
+  RestTemplate restTemplate = new TestRestTemplate();
+
+  @Value("${local.server.port}")
+  int port;
+}

apollo-adminservice/src/test/java/com/ctrip/apollo/adminservice/controller/AppControllerTest.java

@@ -2,36 +2,20 @@ package com.ctrip.apollo.adminservice.controller;
 
 import org.junit.Assert;
 import org.junit.Test;
-import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.boot.test.SpringApplicationConfiguration;
-import org.springframework.boot.test.TestRestTemplate;
-import org.springframework.boot.test.WebIntegrationTest;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-import org.springframework.web.client.RestTemplate;
 
-import com.ctrip.apollo.AdminServiceTestConfiguration;
 import com.ctrip.apollo.biz.entity.App;
 import com.ctrip.apollo.biz.repository.AppRepository;
 import com.ctrip.apollo.biz.utils.BeanUtils;
 import com.ctrip.apollo.core.dto.AppDTO;
 
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringApplicationConfiguration(classes = AdminServiceTestConfiguration.class)
-@WebIntegrationTest(randomPort = true)
-public class AppControllerTest {
-
-  RestTemplate restTemplate = new TestRestTemplate();
+public class AppControllerTest extends AbstractControllerTest{
 
   @Autowired
   AppRepository appRepository;
 
-  @Value("${local.server.port}")
-  private int port;
-  
   private String getBaseAppUrl(){
     return "http://localhost:"+port+"/apps/";
   }

apollo-adminservice/src/test/java/com/ctrip/apollo/adminservice/controller/ItemSetControllerTest.java

+package com.ctrip.apollo.adminservice.controller;
+
+import java.util.List;
+
+import org.junit.Assert;
+import org.junit.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.test.context.jdbc.Sql;
+import org.springframework.test.context.jdbc.Sql.ExecutionPhase;
+
+import com.ctrip.apollo.biz.entity.Item;
+import com.ctrip.apollo.biz.repository.ItemRepository;
+import com.ctrip.apollo.core.dto.AppDTO;
+import com.ctrip.apollo.core.dto.ClusterDTO;
+import com.ctrip.apollo.core.dto.ItemChangeSets;
+import com.ctrip.apollo.core.dto.ItemDTO;
+import com.ctrip.apollo.core.dto.NamespaceDTO;
+
+
+
+public class ItemSetControllerTest extends AbstractControllerTest {
+
+  @Autowired
+  ItemRepository itemRepository;
+
+  @Test
+  @Sql(scripts = "/controller/test-itemset.sql", executionPhase = ExecutionPhase.BEFORE_TEST_METHOD)
+  @Sql(scripts = "/controller/test-itemset-cleanup.sql", executionPhase = ExecutionPhase.AFTER_TEST_METHOD)
+  public void testItemSetCreated() {
+    String appId = "someAppId";
+    AppDTO app =
+        restTemplate.getForObject("http://localhost:" + port + "/apps/" + appId, AppDTO.class);
+
+    ClusterDTO cluster = restTemplate.getForObject(
+        "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/default",
+        ClusterDTO.class);
+
+    NamespaceDTO namespace =
+        restTemplate.getForObject("http://localhost:" + port + "/apps/" + app.getAppId()
+            + "/clusters/" + cluster.getName() + "/namespaces/application", NamespaceDTO.class);
+
+    Assert.assertEquals("someAppId", app.getAppId());
+    Assert.assertEquals("default", cluster.getName());
+    Assert.assertEquals("application", namespace.getNamespaceName());
+
+    ItemChangeSets itemSet = new ItemChangeSets();
+    itemSet.setModifyBy("created");
+
+    int createdSize = 3;
+    for (int i = 0; i < createdSize; i++) {
+      ItemDTO item = new ItemDTO();
+      item.setNamespaceId(namespace.getId());
+      item.setKey("key_" + i);
+      item.setValue("created_value_" + i);
+      itemSet.addCreateItem(item);
+    }
+
+    ResponseEntity<Void> response =
+        restTemplate.postForEntity(
+            "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/"
+                + cluster.getName() + "/namespaces/" + namespace.getNamespaceName() + "/itemset",
+            itemSet, Void.class);
+    Assert.assertEquals(HttpStatus.OK, response.getStatusCode());
+    List<Item> items = itemRepository.findByNamespaceIdOrderByLineNumAsc(namespace.getId());
+    Assert.assertEquals(createdSize, items.size());
+    Item item0 = items.get(0);
+    Assert.assertEquals("key_0", item0.getKey());
+    Assert.assertEquals("created_value_0", item0.getValue());
+    Assert.assertEquals("created", item0.getDataChangeCreatedBy());
+    Assert.assertNotNull(item0.getDataChangeCreatedTime());
+  }
+
+  @Test
+  @Sql(scripts = "/controller/test-itemset.sql", executionPhase = ExecutionPhase.BEFORE_TEST_METHOD)
+  @Sql(scripts = "/controller/test-itemset-cleanup.sql", executionPhase = ExecutionPhase.AFTER_TEST_METHOD)
+  public void testItemSetUpdated() {
+    String appId = "someAppId";
+    AppDTO app =
+        restTemplate.getForObject("http://localhost:" + port + "/apps/" + appId, AppDTO.class);
+
+    ClusterDTO cluster = restTemplate.getForObject(
+        "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/default",
+        ClusterDTO.class);
+
+    NamespaceDTO namespace =
+        restTemplate.getForObject("http://localhost:" + port + "/apps/" + app.getAppId()
+            + "/clusters/" + cluster.getName() + "/namespaces/application", NamespaceDTO.class);
+
+    Assert.assertEquals("someAppId", app.getAppId());
+    Assert.assertEquals("default", cluster.getName());
+    Assert.assertEquals("application", namespace.getNamespaceName());
+
+    ItemChangeSets createChangeSet = new ItemChangeSets();
+    createChangeSet.setModifyBy("created");
+
+    int createdSize = 3;
+    for (int i = 0; i < createdSize; i++) {
+      ItemDTO item = new ItemDTO();
+      item.setNamespaceId(namespace.getId());
+      item.setKey("key_" + i);
+      item.setValue("created_value_" + i);
+      createChangeSet.addCreateItem(item);
+    }
+
+    ResponseEntity<Void> response = restTemplate.postForEntity(
+        "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/" + cluster.getName()
+            + "/namespaces/" + namespace.getNamespaceName() + "/itemset",
+        createChangeSet, Void.class);
+    Assert.assertEquals(HttpStatus.OK, response.getStatusCode());
+
+    ItemDTO[] items =
+        restTemplate.getForObject(
+            "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/"
+                + cluster.getName() + "/namespaces/" + namespace.getNamespaceName() + "/items",
+            ItemDTO[].class);
+
+    ItemChangeSets udpateChangeSet = new ItemChangeSets();
+    udpateChangeSet.setModifyBy("updated");
+
+    int updatedSize = 2;
+    for (int i = 0; i < updatedSize; i++) {
+      items[i].setValue("updated_value_" + i);
+      udpateChangeSet.addUpdateItem(items[i]);
+    }
+
+    response = restTemplate.postForEntity(
+        "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/" + cluster.getName()
+            + "/namespaces/" + namespace.getNamespaceName() + "/itemset",
+        udpateChangeSet, Void.class);
+    Assert.assertEquals(HttpStatus.OK, response.getStatusCode());
+    List<Item> savedItems = itemRepository.findByNamespaceIdOrderByLineNumAsc(namespace.getId());
+    Assert.assertEquals(createdSize, savedItems.size());
+    Item item0 = savedItems.get(0);
+    Assert.assertEquals("key_0", item0.getKey());
+    Assert.assertEquals("updated_value_0", item0.getValue());
+    Assert.assertEquals("created", item0.getDataChangeCreatedBy());
+    Assert.assertEquals("updated", item0.getDataChangeLastModifiedBy());
+    Assert.assertNotNull(item0.getDataChangeCreatedTime());
+    Assert.assertNotNull(item0.getDataChangeLastModifiedTime());
+  }
+
+  @Test
+  @Sql(scripts = "/controller/test-itemset.sql", executionPhase = ExecutionPhase.BEFORE_TEST_METHOD)
+  @Sql(scripts = "/controller/test-itemset-cleanup.sql", executionPhase = ExecutionPhase.AFTER_TEST_METHOD)
+  public void testItemSetDeleted() {
+    String appId = "someAppId";
+    AppDTO app =
+        restTemplate.getForObject("http://localhost:" + port + "/apps/" + appId, AppDTO.class);
+
+    ClusterDTO cluster = restTemplate.getForObject(
+        "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/default",
+        ClusterDTO.class);
+
+    NamespaceDTO namespace =
+        restTemplate.getForObject("http://localhost:" + port + "/apps/" + app.getAppId()
+            + "/clusters/" + cluster.getName() + "/namespaces/application", NamespaceDTO.class);
+
+    Assert.assertEquals("someAppId", app.getAppId());
+    Assert.assertEquals("default", cluster.getName());
+    Assert.assertEquals("application", namespace.getNamespaceName());
+
+    ItemChangeSets createChangeSet = new ItemChangeSets();
+    createChangeSet.setModifyBy("created");
+
+    int createdSize = 3;
+    for (int i = 0; i < createdSize; i++) {
+      ItemDTO item = new ItemDTO();
+      item.setNamespaceId(namespace.getId());
+      item.setKey("key_" + i);
+      item.setValue("created_value_" + i);
+      createChangeSet.addCreateItem(item);
+    }
+
+    ResponseEntity<Void> response = restTemplate.postForEntity(
+        "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/" + cluster.getName()
+            + "/namespaces/" + namespace.getNamespaceName() + "/itemset",
+        createChangeSet, Void.class);
+    Assert.assertEquals(HttpStatus.OK, response.getStatusCode());
+
+    ItemDTO[] items =
+        restTemplate.getForObject(
+            "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/"
+                + cluster.getName() + "/namespaces/" + namespace.getNamespaceName() + "/items",
+            ItemDTO[].class);
+
+    ItemChangeSets deleteChangeSet = new ItemChangeSets();
+    deleteChangeSet.setModifyBy("deleted");
+
+    int deletedSize = 1;
+    for (int i = 0; i < deletedSize; i++) {
+      items[i].setValue("deleted_value_" + i);
+      deleteChangeSet.addDeleteItem(items[i]);
+    }
+
+    response = restTemplate.postForEntity(
+        "http://localhost:" + port + "/apps/" + app.getAppId() + "/clusters/" + cluster.getName()
+            + "/namespaces/" + namespace.getNamespaceName() + "/itemset",
+        deleteChangeSet, Void.class);
+    Assert.assertEquals(HttpStatus.OK, response.getStatusCode());
+    List<Item> savedItems = itemRepository.findByNamespaceIdOrderByLineNumAsc(namespace.getId());
+    Assert.assertEquals(createdSize - deletedSize, savedItems.size());
+    Item item0 = savedItems.get(0);
+    Assert.assertEquals("key_1", item0.getKey());
+    Assert.assertEquals("created_value_1", item0.getValue());
+    Assert.assertEquals("created", item0.getDataChangeCreatedBy());
+    Assert.assertNotNull(item0.getDataChangeCreatedTime());
+  }
+}

apollo-adminservice/src/test/resources/application.properties

-spring.datasource.url = jdbc:h2:mem:~/fxapolloconfigdb;mode=mysql;DB_CLOSE_ON_EXIT=FALSE
+spring.datasource.url = jdbc:h2:mem:~/apolloconfigdb;mode=mysql;DB_CLOSE_ON_EXIT=FALSE;DB_CLOSE_DELAY=-1
 spring.jpa.hibernate.naming_strategy=org.hibernate.cfg.EJB3NamingStrategy
+spring.jpa.properties.hibernate.show_sql=true
 spring.h2.console.enabled = true
 spring.h2.console.settings.web-allow-others=true
+

apollo-adminservice/src/test/resources/controller/test-itemset-cleanup.sql

+DELETE FROM Item;
+DELETE FROM Namespace;
+DELETE FROM AppNamespace;
+DELETE FROM Cluster;
+DELETE FROM App;
+

apollo-adminservice/src/test/resources/controller/test-itemset.sql

+INSERT INTO App (AppId, Name, OwnerName, OwnerEmail) VALUES ('someAppId','someAppName','someOwnerName','someOwnerName@ctrip.com');
+
+INSERT INTO Cluster (AppId, Name) VALUES ('someAppId', 'default');
+
+INSERT INTO AppNamespace (AppId, Name) VALUES ('someAppId', 'application');
+
+INSERT INTO Namespace (AppId, ClusterName, NamespaceName) VALUES ('someAppId', 'default', 'application');

apollo-biz/src/main/java/com/ctrip/apollo/biz/entity/BaseEntity.java

@@ -20,8 +20,8 @@ public abstract class BaseEntity {
   @GeneratedValue
   private long id;
 
-  @Column(name = "IsDeleted")
-  protected boolean isDeleted;
+  @Column(name = "IsDeleted", columnDefinition="Bit default '0'")
+  protected boolean isDeleted = false;
 
   @Column(name = "DataChange_CreatedBy")
   private String dataChangeCreatedBy;

apollo-biz/src/main/java/com/ctrip/apollo/biz/service/ItemSetService.java

@@ -4,51 +4,43 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import com.ctrip.apollo.biz.entity.Item;
-import com.ctrip.apollo.biz.entity.Namespace;
 import com.ctrip.apollo.biz.repository.ItemRepository;
-import com.ctrip.apollo.biz.repository.NamespaceRepository;
 import com.ctrip.apollo.biz.utils.BeanUtils;
 import com.ctrip.apollo.core.dto.ItemChangeSets;
 import com.ctrip.apollo.core.dto.ItemDTO;
 
-import java.util.Date;
-
 @Service
 public class ItemSetService {
 
   @Autowired
   private ItemRepository itemRepository;
-  @Autowired
-  private NamespaceRepository namespaceRepository;
-
-  public void updateSet(String appId, String clusterName, String namespaceName, ItemChangeSets changeSet) {
-    Namespace namespace = namespaceRepository.findByAppIdAndClusterNameAndNamespaceName(appId, clusterName, namespaceName);
 
-    String modifyBy = changeSet.getModifyBy();
-    for (ItemDTO item : changeSet.getCreateItems()) {
-      Item entity = BeanUtils.transfrom(Item.class, item);
-
-      entity.setNamespaceId(namespace.getId());
-      entity.setDataChangeCreatedBy(modifyBy);
-      entity.setDataChangeCreatedTime(new Date());
-      entity.setDataChangeLastModifiedBy(modifyBy);
-      itemRepository.save(entity);
+  public void updateSet(ItemChangeSets changeSet) {
+    if (changeSet.getCreateItems() != null) {
+      for (ItemDTO item : changeSet.getCreateItems()) {
+        Item entity = BeanUtils.transfrom(Item.class, item);
+        entity.setDataChangeCreatedBy(changeSet.getModifyBy());
+        itemRepository.save(entity);
+      }
     }
 
-    for (ItemDTO item : changeSet.getUpdateItems()) {
-      Item entity = BeanUtils.transfrom(Item.class, item);
-      Item managedItem = itemRepository.findOne(entity.getId());
-      if (managedItem != null){
-        BeanUtils.copyEntityProperties(entity, managedItem, "id", "namespaceId", "key", "dataChangeCreatedBy", "dataChangeCreatedTime");
-        managedItem.setDataChangeLastModifiedBy(modifyBy);
+    if (changeSet.getUpdateItems() != null) {
+      for (ItemDTO item : changeSet.getUpdateItems()) {
+        Item entity = BeanUtils.transfrom(Item.class, item);
+        Item managedItem = itemRepository.findOne(entity.getId());
+        BeanUtils.copyEntityProperties(entity, managedItem);
+        managedItem.setDataChangeLastModifiedBy(changeSet.getModifyBy());
+        itemRepository.save(managedItem);
       }
-      itemRepository.save(managedItem);
     }
 
-    for (ItemDTO item : changeSet.getDeletedItems()) {
-      Item entity = BeanUtils.transfrom(Item.class, item);
-      entity.setDataChangeLastModifiedBy(modifyBy);
-      itemRepository.delete(entity.getId());
+    if (changeSet.getDeleteItems() != null) {
+      for (ItemDTO item : changeSet.getDeleteItems()) {
+        Item entity = BeanUtils.transfrom(Item.class, item);
+        entity.setDataChangeLastModifiedBy(changeSet.getModifyBy());
+        itemRepository.save(entity);
+        itemRepository.delete(item.getId());
+      }
     }
   }
 }

apollo-biz/src/main/java/com/ctrip/apollo/biz/utils/BeanUtils.java

@@ -209,12 +209,22 @@ public class BeanUtils {
   }
 
   /**
-   * The copy will ignore <em>id</em> field
    * 
    * @param source
    * @param target
    */
-  public static void copyEntityProperties(Object source, Object target, String... ignoreProperties) {
+  public static void copyProperties(Object source, Object target, String... ignoreProperties) {
     org.springframework.beans.BeanUtils.copyProperties(source, target, ignoreProperties);
   }
+  
+  /**
+   * The copy will ignore <em>BaseEntity</em> field
+   * 
+   * @param source
+   * @param target
+   */
+  public static void copyEntityProperties(Object source, Object target) {
+    org.springframework.beans.BeanUtils.copyProperties(source, target, "id", "dataChangeCreatedBy",
+        "dataChangeCreatedTime", "dataChangeLastModifiedBy", "dataChangeLastModifiedTime");
+  }
 }

apollo-configservice/src/main/java/com/ctrip/apollo/configservice/controller/WebMvcConfig.java

@@ -8,7 +8,6 @@ import org.springframework.data.web.PageableHandlerMethodArgumentResolver;
 import org.springframework.http.MediaType;
 import org.springframework.web.method.support.HandlerMethodArgumentResolver;
 import org.springframework.web.servlet.config.annotation.ContentNegotiationConfigurer;
-import org.springframework.web.servlet.config.annotation.EnableWebMvc;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
 
 @Configuration

apollo-configservice/src/test/resources/application.properties

-spring.datasource.url = jdbc:h2:mem:~/fxapolloconfigdb;mode=mysql
+spring.datasource.url = jdbc:h2:mem:~/apolloconfigdb;mode=mysql
 spring.jpa.hibernate.naming_strategy=org.hibernate.cfg.EJB3NamingStrategy
 spring.h2.console.enabled = true
 spring.h2.console.settings.web-allow-others=true
-hibernate.globally_quoted_identifiers=true
-hibernate.show_sql=true
\ No newline at end of file
+spring.jpa.properties.hibernate.show_sql=true
\ No newline at end of file

apollo-core/src/main/java/com/ctrip/apollo/core/dto/ItemChangeSets.java

@@ -11,9 +11,9 @@ public class ItemChangeSets {
   private String modifyBy;
   private List<ItemDTO> createItems = new LinkedList<>();
   private List<ItemDTO> updateItems = new LinkedList<>();
-  private List<ItemDTO> deletedItems = new LinkedList<>();
+  private List<ItemDTO> deleteItems = new LinkedList<>();
 
-  public void addCreatedItem(ItemDTO item) {
+  public void addCreateItem(ItemDTO item) {
     createItems.add(item);
   }
 
@@ -21,11 +21,10 @@ public class ItemChangeSets {
     updateItems.add(item);
   }
 
-  public void addDeletedItem(ItemDTO item) {
-    deletedItems.add(item);
+  public void addDeleteItem(ItemDTO item) {
+    deleteItems.add(item);
   }
 
-
   public List<ItemDTO> getCreateItems() {
     return createItems;
   }
@@ -34,8 +33,8 @@ public class ItemChangeSets {
     return updateItems;
   }
 
-  public List<ItemDTO> getDeletedItems() {
-    return deletedItems;
+  public List<ItemDTO> getDeleteItems() {
+    return deleteItems;
   }
 
   public void setCreateItems(List<ItemDTO> createItems) {
@@ -46,8 +45,8 @@ public class ItemChangeSets {
     this.updateItems = updateItems;
   }
 
-  public void setDeletedItems(List<ItemDTO> deletedItems) {
-    this.deletedItems = deletedItems;
+  public void setDeleteItems(List<ItemDTO> deleteItems) {
+    this.deleteItems = deleteItems;
   }
 
   public String getModifyBy() {

apollo-portal/src/main/java/com/ctrip/apollo/portal/service/txtresolver/SimpleKVCResolver.java

+package com.ctrip.apollo.portal.service.txtresolver;
+
+import com.ctrip.apollo.core.dto.ItemChangeSets;
+import com.ctrip.apollo.core.dto.ItemDTO;
+import com.ctrip.apollo.core.utils.StringUtils;
+import com.ctrip.apollo.portal.util.BeanUtils;
+
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * config item format is K:V##C
+ *
+ * @Autor lepdou
+ */
+
+@Component
+public class SimpleKVCResolver implements ConfigTextResolver {
+
+  private static final String KV_SEPARATOR = ":";
+  private static final String VC_SEPARATOR = "##";
+  private static final String ITEM_SEPARATOR = "\n";
+
+
+  @Override
+  public TextResolverResult resolve(String configText, List<ItemDTO> baseItems) {
+    TextResolverResult result = new TextResolverResult();
+
+    if (StringUtils.isEmpty(configText)) {
+      result.setCode(TextResolverResult.Code.SIMPLE_KVC_TEXT_EMPTY);
+      return result;
+    }
+    Map<String, ItemDTO> baseKeyMapItem = BeanUtils.mapByKey("key", baseItems);
+
+    String[] items = configText.split(ITEM_SEPARATOR);
+
+    ItemChangeSets changeSets = new ItemChangeSets();
+
+    int lineCounter = 1;
+    int kvSeparator, vcSeparator;
+    String key, value, comment;
+    for (String item : items) {
+      kvSeparator = item.indexOf(KV_SEPARATOR);
+      vcSeparator = item.indexOf(VC_SEPARATOR);
+      if (kvSeparator == -1 || vcSeparator == -1) {
+        result.setCode(TextResolverResult.Code.SIMPLTE_KVC_INVALID_FORMAT);
+        result.setExtensionMsg(" line:" + lineCounter);
+        return result;
+      }
+
+      key = item.substring(0, kvSeparator).trim();
+      value = item.substring(kvSeparator + 1, vcSeparator).trim();
+      comment = item.substring(vcSeparator + 2, item.length()).trim();
+
+      ItemDTO baseItem = baseKeyMapItem.get(key);
+      if (baseItem == null) {//new item
+        changeSets.addCreateItem(buildItem(key, value, comment));
+      } else if (!value.equals(baseItem.getValue()) || !comment.equals(baseItem.getComment())) {//update item
+        changeSets.addUpdateItem(buildItem(key, value, comment));
+      }
+
+      //deleted items:items in baseItems but not in configText
+      baseKeyMapItem.remove(key);
+
+      lineCounter ++;
+    }
+
+    //deleted items
+    for (Map.Entry<String, ItemDTO> entry : baseKeyMapItem.entrySet()) {
+      changeSets.addDeleteItem(entry.getValue());
+    }
+
+    result.setCode(TextResolverResult.Code.OK);
+    result.setChangeSets(changeSets);
+    return result;
+  }
+
+  private ItemDTO buildItem(String key, String value, String comment) {
+    ItemDTO item = new ItemDTO();
+    item.setKey(key);
+    item.setValue(value);
+    item.setComment(comment);
+    return item;
+  }
+
+
+}