Author: jleroux
Date: Thu Jun 27 11:49:22 2019
New Revision: 1862206
URL: http://svn.apache.org/viewvc?rev=1862206&view=rev
Log:
Implemented: JSON entity data import and export utility
(OFBIZ-10966)
Currently, we support import/export entity data in XML format.
Nowadays JSON is widely used in industry, we can have support for JSON format
which looks quite similar to XML support.
Here is example of XML data and it's JSON version
<Party partyId="123456" partyTypeId="PERSON" statusId="PARTY_ENABLED"/>
{“Party”:
{"partyId":"123456","partyTypeId":"PERSON","statusId":"PARTY_ENABLED”}}
Design Proposal
We can write entityImportJson and entityImportDirJson services for importing
JSON from screen and directory respectively.
And the entityExportAllJson service for exporting entity data in JSON.
Import Design
The import service will perform following operations:
1.) Validate the input JSON data
2.) On successful validation, convert JSON to OFBiz's entity model
(GenericValue)
3.) The GenericValue will be inserted in database by some handler class for
e.g
we can write JsonDataHandler, it will convert given JSON to
List<GenericValue>, and finally write it to database
(Similar pattern is used in XML import).
Export Design
Based on existing XML pattern the writeXmlText method of GenericEntity class
write the exported data in XML format.
In the similar way, we can implement writeJsonText to export data in JSON
format.
jleroux: I fixed 2 trivials things and at my request in last patch Jayansh
added
"JSON Data Export All" and "JSON Data Import Dir
Thanks: Jayansh Shinde
Added:
ofbiz/ofbiz-framework/trunk/framework/entity/src/main/java/org/apache/ofbiz/entity/util/EntityJsonReader.java
(with props)
ofbiz/ofbiz-framework/trunk/framework/webtools/groovyScripts/entity/JsonDsDump.groovy
(with props)
ofbiz/ofbiz-framework/trunk/framework/webtools/src/main/java/org/apache/ofbiz/webtools/EntityJsonEvents.java
(with props)
ofbiz/ofbiz-framework/trunk/framework/webtools/src/main/java/org/apache/ofbiz/webtools/EntityJsonHelper.java
(with props)
ofbiz/ofbiz-framework/trunk/framework/webtools/template/entity/EntityExportAllJson.ftl
(with props)
ofbiz/ofbiz-framework/trunk/framework/webtools/template/entity/EntityImportDirJson.ftl
(with props)
ofbiz/ofbiz-framework/trunk/framework/webtools/template/entity/EntityImportJson.ftl
(with props)
ofbiz/ofbiz-framework/trunk/framework/webtools/template/entity/JsonDsDump.ftl
(with props)
Modified:
ofbiz/ofbiz-framework/trunk/applications/commonext/webapp/ofbizsetup/WEB-INF/controller.xml
ofbiz/ofbiz-framework/trunk/applications/commonext/widget/ofbizsetup/CommonScreens.xml
ofbiz/ofbiz-framework/trunk/build.gradle
ofbiz/ofbiz-framework/trunk/framework/webtools/config/WebtoolsUiLabels.xml
ofbiz/ofbiz-framework/trunk/framework/webtools/servicedef/services.xml
ofbiz/ofbiz-framework/trunk/framework/webtools/src/main/java/org/apache/ofbiz/webtools/WebToolsServices.java
ofbiz/ofbiz-framework/trunk/framework/webtools/template/Main.ftl
ofbiz/ofbiz-framework/trunk/framework/webtools/webapp/webtools/WEB-INF/controller.xml
ofbiz/ofbiz-framework/trunk/framework/webtools/widget/EntityScreens.xml
ofbiz/ofbiz-framework/trunk/framework/webtools/widget/Menus.xml
Modified:
ofbiz/ofbiz-framework/trunk/applications/commonext/webapp/ofbizsetup/WEB-INF/controller.xml
URL:
http://svn.apache.org/viewvc/ofbiz/ofbiz-framework/trunk/applications/commonext/webapp/ofbizsetup/WEB-INF/controller.xml?rev=1862206&r1=1862205&r2=1862206&view=diff
==============================================================================
---
ofbiz/ofbiz-framework/trunk/applications/commonext/webapp/ofbizsetup/WEB-INF/controller.xml
(original)
+++
ofbiz/ofbiz-framework/trunk/applications/commonext/webapp/ofbizsetup/WEB-INF/controller.xml
Thu Jun 27 11:49:22 2019
@@ -58,6 +58,17 @@
<response name="success" type="view" value="EntityExportAll"/>
<response name="error" type="view" value="EntityExportAll"/>
</request-map>
+ <request-map uri="EntityExportAllJson">
+ <security https="true" auth="true"/>
+ <response name="success" type="view" value="EntityExportAllJson"/>
+ <response name="error" type="view" value="EntityExportAllJson"/>
+ </request-map>
+ <request-map uri="entityExportAllJson">
+ <security https="true" auth="true"/>
+ <event type="service" path="" invoke="entityExportAllJson"/>
+ <response name="success" type="view" value="EntityExportAllJson"/>
+ <response name="error" type="view" value="EntityExportAllJson"/>
+ </request-map>
<!-- ================ Product Store Requests ============= -->
<request-map uri="FindProductStore">
@@ -206,6 +217,7 @@
<view-map name="EditProductStore" type="screen"
page="component://commonext/widget/ofbizsetup/SetupScreens.xml#EditProductStore"/>
<view-map name="EntityExportAll" type="screen"
page="component://commonext/widget/ofbizsetup/CommonScreens.xml#EntityExportAll"/>
+ <view-map name="EntityExportAllJson" type="screen"
page="component://commonext/widget/ofbizsetup/CommonScreens.xml#EntityExportAllJson"/>
<view-map name="FindWebSite" type="screen"
page="component://commonext/widget/ofbizsetup/SetupScreens.xml#FindWebSite"/>
<view-map name="EditWebSite" type="screen"
page="component://commonext/widget/ofbizsetup/SetupScreens.xml#EditWebSite"/>
Modified:
ofbiz/ofbiz-framework/trunk/applications/commonext/widget/ofbizsetup/CommonScreens.xml
URL:
http://svn.apache.org/viewvc/ofbiz/ofbiz-framework/trunk/applications/commonext/widget/ofbizsetup/CommonScreens.xml?rev=1862206&r1=1862205&r2=1862206&view=diff
==============================================================================
---
ofbiz/ofbiz-framework/trunk/applications/commonext/widget/ofbizsetup/CommonScreens.xml
(original)
+++
ofbiz/ofbiz-framework/trunk/applications/commonext/widget/ofbizsetup/CommonScreens.xml
Thu Jun 27 11:49:22 2019
@@ -153,4 +153,26 @@
</widgets>
</section>
</screen>
+ <screen name="EntityExportAllJson">
+ <section>
+ <actions>
+ <set field="titleProperty"
value="PageTitleEntityExportAllJson"/>
+ <set field="tabButtonItem" value="entityExportAllJson"/>
+ <set field="parameters.TRANSACTION_TIMEOUT" value="7200"/>
+ <set field="results" from-field="parameters.results"/>
+ <set field="headerItem" value="export"/>
+ </actions>
+ <widgets>
+ <decorator-screen name="main-decorator"
location="${parameters.mainDecoratorLocation}">
+ <decorator-section name="body">
+ <screenlet
title="${uiLabelMap.PageTitleEntityExportAllJson}">
+ <platform-specific>
+ <html><html-template
location="component://webtools/template/entity/EntityExportAllJson.ftl"/></html>
+ </platform-specific>
+ </screenlet>
+ </decorator-section>
+ </decorator-screen>
+ </widgets>
+ </section>
+ </screen>
</screens>
Modified: ofbiz/ofbiz-framework/trunk/build.gradle
URL:
http://svn.apache.org/viewvc/ofbiz/ofbiz-framework/trunk/build.gradle?rev=1862206&r1=1862205&r2=1862206&view=diff
==============================================================================
--- ofbiz/ofbiz-framework/trunk/build.gradle (original)
+++ ofbiz/ofbiz-framework/trunk/build.gradle Thu Jun 27 11:49:22 2019
@@ -209,6 +209,7 @@ dependencies {
implementation 'wsdl4j:wsdl4j:1.6.3'
implementation 'org.jsoup:jsoup:1.11.3'
implementation 'io.jsonwebtoken:jjwt:0.9.1'
+ implementation 'org.json:json:20140107'
testImplementation 'org.mockito:mockito-core:2.27.0'
runtimeOnly 'javax.xml.soap:javax.xml.soap-api:1.4.0'
runtimeOnly 'de.odysseus.juel:juel-spi:2.2.7'
Added:
ofbiz/ofbiz-framework/trunk/framework/entity/src/main/java/org/apache/ofbiz/entity/util/EntityJsonReader.java
URL:
http://svn.apache.org/viewvc/ofbiz/ofbiz-framework/trunk/framework/entity/src/main/java/org/apache/ofbiz/entity/util/EntityJsonReader.java?rev=1862206&view=auto
==============================================================================
---
ofbiz/ofbiz-framework/trunk/framework/entity/src/main/java/org/apache/ofbiz/entity/util/EntityJsonReader.java
(added)
+++
ofbiz/ofbiz-framework/trunk/framework/entity/src/main/java/org/apache/ofbiz/entity/util/EntityJsonReader.java
Thu Jun 27 11:49:22 2019
@@ -0,0 +1,598 @@
+package org.apache.ofbiz.entity.util;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.ofbiz.base.lang.JSON;
+import org.apache.ofbiz.base.util.Base64;
+import org.apache.ofbiz.base.util.Debug;
+import org.apache.ofbiz.base.util.UtilMisc;
+import org.apache.ofbiz.base.util.UtilValidate;
+import org.apache.ofbiz.entity.Delegator;
+import org.apache.ofbiz.entity.GenericEntityException;
+import org.apache.ofbiz.entity.GenericEntityNotFoundException;
+import org.apache.ofbiz.entity.GenericValue;
+import org.apache.ofbiz.entity.datasource.GenericHelper;
+import org.apache.ofbiz.entity.eca.EntityEcaHandler;
+import org.apache.ofbiz.entity.model.ModelEntity;
+import org.apache.ofbiz.entity.model.ModelField;
+import org.apache.ofbiz.entity.transaction.GenericTransactionException;
+import org.apache.ofbiz.entity.transaction.TransactionUtil;
+import org.json.JSONArray;
+import org.json.JSONObject;
+
+public class EntityJsonReader {
+ public static final String module = EntitySaxReader.class.getName();
+ public static final int DEFAULT_TX_TIMEOUT = 7200;
+ private Delegator delegator;
+ private EntityEcaHandler<?> ecaHandler = null;
+ private long numberRead = 0;
+ private long numberCreated = 0;
+ private long numberUpdated = 0;
+ private long numberReplaced = 0;
+ private long numberDeleted = 0;
+ private long numberSkipped = 0;
+
+ private int valuesPerWrite = 100;
+ private int valuesPerMessage = 1000;
+ private int transactionTimeout = 7200;
+ private boolean useTryInsertMethod = false;
+ private boolean maintainTxStamps = false;
+ private boolean createDummyFks = false;
+ private boolean checkDataOnly = false;
+ private boolean continueOnFail = false;
+
+ private List<Object> messageList = null;
+
+ private List<GenericValue> valuesToCreate = new
ArrayList<>(valuesPerWrite);
+ private List<GenericValue> valuesToDelete = new
ArrayList<>(valuesPerWrite);
+ private List<GenericValue> valuesToUpdate = new
ArrayList<>(valuesPerWrite);
+
+ /**TODO need to evaluate how placeholders are going to be used in json
data*/
+ private Map<String, Object> placeholderValues = null; //contains map of
values for corresponding placeholders (eg. ${key}) in the entity xml data file.
+
+ protected EntityJsonReader() {
+ }
+
+ public EntityJsonReader(Delegator delegator, int transactionTimeout) {
+ this.delegator = delegator.cloneDelegator();
+ this.transactionTimeout = transactionTimeout;
+ }
+
+ public EntityJsonReader(Delegator delegator) {
+ this(delegator, DEFAULT_TX_TIMEOUT);
+ }
+
+ public int getTransactionTimeout() {
+ return this.transactionTimeout;
+ }
+
+ public void setUseTryInsertMethod(boolean value) {
+ this.useTryInsertMethod = value;
+ }
+
+ public void setTransactionTimeout(int transactionTimeout) throws
GenericTransactionException {
+ if (this.transactionTimeout != transactionTimeout) {
+ TransactionUtil.setTransactionTimeout(transactionTimeout);
+ this.transactionTimeout = transactionTimeout;
+ }
+
+ }
+
+ public void setMaintainTxStamps(boolean maintainTxStamps) {
+ this.maintainTxStamps = maintainTxStamps;
+ }
+
+ public void setCreateDummyFks(boolean createDummyFks) {
+ this.createDummyFks = createDummyFks;
+ }
+
+ public void setCheckDataOnly(boolean checkDataOnly) {
+ this.checkDataOnly = checkDataOnly;
+ }
+
+ public void setContinueOnFail(boolean continueOnFail) {
+ this.continueOnFail = continueOnFail;
+ }
+
+ public void setPlaceholderValues(Map<String, Object> placeholderValues) {
+ this.placeholderValues = placeholderValues;
+ }
+
+ public List<Object> getMessageList() {
+ if (this.checkDataOnly && this.messageList == null) {
+ this.messageList = new LinkedList();
+ }
+
+ return this.messageList;
+ }
+
+ public void setDisableEeca(boolean disableEeca) {
+ if (disableEeca) {
+ if (this.ecaHandler == null) {
+ this.ecaHandler = this.delegator.getEntityEcaHandler();
+ }
+
+ this.delegator.setEntityEcaHandler((EntityEcaHandler) null);
+ } else if (this.ecaHandler != null) {
+ this.delegator.setEntityEcaHandler(this.ecaHandler);
+ }
+
+ }
+
+ public long parse(String content) throws IOException {
+ if (content == null) {
+ Debug.logWarning("content was null, doing nothing", module);
+ return 0L;
+ } else {
+ return this.convertJsonAndWriteValues(content);
+ }
+ }
+
+ public long parse(URL location) throws IOException {
+ if (location == null) {
+ Debug.logWarning("location URL was null, doing nothing", module);
+ return 0L;
+ } else {
+ Debug.logImportant("Beginning import from URL: " +
location.toExternalForm(), module);
+ long numberRead = 0L;
+ InputStream is = location.openStream();
+ numberRead = this.parse(is, location.toString());
+ return numberRead;
+ }
+ }
+
+ private long parse(InputStream is, String docDescription) throws
IOException {
+ JSON json = JSON.from(is);
+ return this.convertJsonAndWriteValues(json.toString());
+ }
+
+ private long convertJsonAndWriteValues(String jsonString) throws
IOException {
+ this.numberRead = 0L;
+ String _prefix = "";
+ JSONArray jsonArray = new JSONArray(jsonString);
+ int length = jsonArray.length();
+
+ for (int jsonIndex = 0; jsonIndex < length; ++jsonIndex) {
+ JSONObject jsonObject = jsonArray.getJSONObject(jsonIndex);
+ Map<String, Map<String, Object>> flatJson = new HashMap<String,
Map<String, Object>>();
+ Iterator iterator = jsonObject.keySet().iterator();
+
+ while (iterator.hasNext()) {
+ String key = iterator.next().toString();
+ /**TODO use something else instead of if-else */
+ if (key.equals("create")) {
+ action(jsonObject.get(key), "create");
+ } else if (key.equals("create-update")) {
+ action(jsonObject.get(key), "createUpdate");
+ } else if (key.equals("create-replace")) {
+ action(jsonObject.get(key), "createReplace");
+ } else if (key.equals("delete")) {
+ action(jsonObject.get(key), "delete");
+ } else {
+ /**TODO replace this block with createUpdate method*/
+ /*Object value = jsonObject.get(key);
+ if (value != null && !value.equals("null") && value
instanceof JSONObject) {
+ flatJson.put(_prefix + key,
this.iterateJSONObject((JSONObject) value));
+ ModelEntity modelEntity =
this.delegator.getModelEntity(key);
+ GenericValue entityVal =
GenericValue.create(this.delegator, modelEntity,
+ this.iterateJSONObject((JSONObject) value));
+ if (UtilValidate.isNotEmpty(entityVal)) {
+ this.valuesToCreate.add(entityVal);
+ }
+ }*/
+ createUpdate(jsonObject);
+ }
+ }
+ }
+
+ this.numberRead = this.writeValues();
+ return this.numberRead;
+ }
+
+ private List<Map<String, Object>> iterateJsonEntityData(Object jsonData) {
+ List<Map<String, Object>> genericMapList = new LinkedList<Map<String,
Object>>();
+ if (jsonData instanceof JSONArray) {
+ JSONArray jsonArray = (JSONArray) jsonData;
+ int length = jsonArray.length();
+ for (int jsonIndex = 0; jsonIndex < length; ++jsonIndex) {
+ JSONObject jsonObject = jsonArray.getJSONObject(jsonIndex);
+ Map<String, Object> genericMap = iterateJSONObject(jsonObject);
+ if (UtilValidate.isNotEmpty(genericMap)) {
+ genericMapList.add(genericMap);
+ }
+ }
+ } else if (jsonData instanceof JSONObject) {
+ JSONObject jsonObject = (JSONObject) jsonData;
+ Map<String, Object> genericMap = iterateJSONObject(jsonObject);
+ if (UtilValidate.isNotEmpty(genericMap)) {
+ genericMapList.add(genericMap);
+ }
+ }
+ return genericMapList;
+ }
+
+ private Map<String, Object> iterateJSONObject(JSONObject jsonObj) {
+ Map<String, Object> mapObj = new HashMap<String, Object>();
+ Iterator iterator = jsonObj.keySet().iterator();
+ while (iterator.hasNext()) {
+ String keyStr = (String) iterator.next();
+ Object keyvalue = jsonObj.get(keyStr);
+ if (keyvalue instanceof String) {
+ String keyValStr =
org.apache.commons.text.StringEscapeUtils.unescapeJson((String) keyvalue);
+ mapObj.put(keyStr, keyValStr);
+ } else {
+ mapObj.put(keyStr, keyvalue);
+ }
+ }
+ return mapObj;
+ }
+
+ private long create(JSONObject jsonObject) throws IOException {
+ Iterator iterator = jsonObject.keySet().iterator();
+ while (iterator.hasNext()) {
+ String key = iterator.next().toString();
+ Object value = jsonObject.get(key);
+ if (UtilValidate.isNotEmpty(value)) {
+ List<Map<String, Object>> genericMapList =
this.iterateJsonEntityData(value);
+ for (Map<String, Object> keyValPair : genericMapList) {
+ try {
+ ModelEntity modelEntity =
this.delegator.getModelEntity(key);
+ GenericValue currentValue = delegator.makeValue(key,
keyValPair);
+ if (this.maintainTxStamps) {
+ currentValue.setIsFromEntitySync(true);
+ }
+ GenericHelper helper =
delegator.getEntityHelper(currentValue.getEntityName());
+ if (UtilValidate.isNotEmpty(currentValue)) {
+ boolean exist = true;
+ if (currentValue.containsPrimaryKey()) {
+ try {
+
helper.findByPrimaryKey(currentValue.getPrimaryKey());
+ } catch (GenericEntityNotFoundException e) {
+ exist = false;
+ }
+ }
+ if (!exist) {
+ if (this.useTryInsertMethod &&
!this.checkDataOnly) {
+ currentValue.create();
+ } else {
+ this.valuesToCreate.add(currentValue);
+ }
+ this.numberCreated++;
+ }//if pk exist ignore it.
+ }
+ } catch (Exception e) {
+ if (continueOnFail) {
+ Debug.logError(e, module);
+ } else {
+ throw new IOException(e);
+ }
+ }
+ }
+ }
+ }
+ return this.numberCreated;
+ }
+
+ private long createUpdate(JSONObject jsonObject) throws IOException {
+ Iterator iterator = jsonObject.keySet().iterator();
+ while (iterator.hasNext()) {
+ String key = iterator.next().toString();
+ Object value = jsonObject.get(key);
+ if (UtilValidate.isNotEmpty(value)) {
+ List<Map<String, Object>> genericMapList =
this.iterateJsonEntityData(value);
+ for (Map<String, Object> keyValPair : genericMapList) {
+ try {
+ GenericValue currentValue = delegator.makeValue(key);
+ if (currentValue != null) {
+ ModelEntity modelEntity =
currentValue.getModelEntity();
+ List<String> pkFields =
modelEntity.getPkFieldNames();
+ for (String pkField : pkFields) {
+ ModelField modelField =
modelEntity.getField(pkField);
+ Object pkFieldValue = keyValPair.get(pkField);
+ String type = modelField.getType();
+ if (type != null && "blob".equals(type)) {
+ byte[] binData =
Base64.base64Decode((pkFieldValue.toString()).getBytes());
+ currentValue.setBytes(pkField, binData);
+ } else {
+ currentValue.setString(pkField,
pkFieldValue.toString());
+ }
+ }
+
+ GenericHelper helper =
delegator.getEntityHelper(currentValue.getEntityName());
+
+ boolean exist = true;
+ if (currentValue.containsPrimaryKey()) {
+ try {
+
helper.findByPrimaryKey(currentValue.getPrimaryKey());
+ } catch (GenericEntityNotFoundException e) {
+ exist = false;
+ }
+ }
+ for (Map.Entry<String, Object> entry :
keyValPair.entrySet()) {
+ String currentFieldName = entry.getKey();
+ Object currentFieldValue = entry.getValue();
+ if (currentFieldName != null &&
!pkFields.contains(currentFieldName)) {
+ if
(currentValue.getModelEntity().isField(currentFieldName)) {
+ if
(UtilValidate.isNotEmpty(currentFieldValue)) {
+ ModelField modelField =
modelEntity.getField(currentFieldName);
+ String type = modelField.getType();
+ if (type != null &&
"blob".equals(type)) {
+ byte[] binData =
Base64.base64Decode(currentFieldValue.toString().getBytes());
+
currentValue.setBytes(currentFieldName, binData);
+ } else {
+
currentValue.setString(currentFieldName, currentFieldValue.toString());
+ }
+ }
+ } else {
+ Debug.logWarning("Ignoring invalid
field name [" + currentFieldName + "] found for the entity: "
+ + currentValue.getEntityName()
+ " with value=" + currentFieldValue.toString(), module);
+ }
+ }
+ }
+ if (exist) {
+ this.valuesToUpdate.add(currentValue);
+ } else {
+ // Not sure about this!
+ //if (this.useTryInsertMethod &&
!this.checkDataOnly) {
+ // currentValue.create();
+ //} else {
+ this.valuesToCreate.add(currentValue);
+ //}
+
+ }
+ if (this.maintainTxStamps) {
+ currentValue.setIsFromEntitySync(true);
+ }
+ this.numberUpdated++;
+ }
+ } catch (Exception e) {
+ if (continueOnFail) {
+ Debug.logError(e, module);
+ } else {
+ throw new IOException(e);
+ }
+ }
+ }
+ }
+ }
+ return this.numberUpdated;
+ }
+
+ private long createReplace(JSONObject jsonObject) throws IOException {
+ Iterator iterator = jsonObject.keySet().iterator();
+ while (iterator.hasNext()) {
+ String key = iterator.next().toString();
+ Object value = jsonObject.get(key);
+ if (UtilValidate.isNotEmpty(value)) {
+ List<Map<String, Object>> genericMapList =
this.iterateJsonEntityData(value);
+ for (Map<String, Object> keyValPair : genericMapList) {
+ try {
+ GenericValue currentValue =
this.delegator.makeValue(key);
+ if (this.maintainTxStamps) {
+ currentValue.setIsFromEntitySync(true);
+ }
+ ModelEntity modelEntity =
currentValue.getModelEntity();
+ List<String> pkFields = modelEntity.getPkFieldNames();
+ if (currentValue != null) {
+ for (String pkField : pkFields) {
+ ModelField modelField =
modelEntity.getField(pkField);
+ Object pkFieldValue = keyValPair.get(pkField);
+ String type = modelField.getType();
+ if (type != null && "blob".equals(type)) {
+ byte[] binData =
Base64.base64Decode((pkFieldValue.toString()).getBytes());
+ currentValue.setBytes(pkField, binData);
+ } else {
+ currentValue.setString(pkField,
pkFieldValue.toString());
+ }
+ }
+
+ GenericHelper helper =
delegator.getEntityHelper(currentValue.getEntityName());
+
+ boolean exist = true;
+ if (currentValue.containsPrimaryKey()) {
+ try {
+
helper.findByPrimaryKey(currentValue.getPrimaryKey());
+ } catch (GenericEntityNotFoundException e) {
+ exist = false;
+ }
+ } else {
+ if (modelEntity.getPksSize() == 1) {
+ ModelField modelField =
currentValue.getModelEntity().getOnlyPk();
+ String newSeq =
delegator.getNextSeqId(currentValue.getEntityName());
+
currentValue.setString(modelField.getName(), newSeq);
+ } else {
+ throw new IOException("Cannot store value
with incomplete primary key with more than 1 primary key field: " +
currentValue);
+ }
+ }
+
+ ModelEntity currentEntity =
currentValue.getModelEntity();
+ List<String> absentFields =
currentEntity.getNoPkFieldNames();
+
absentFields.removeAll(currentEntity.getAutomaticFieldNames());
+
+ for (Map.Entry<String, Object> entry :
keyValPair.entrySet()) {
+ String currentFieldName = entry.getKey();
+ Object currentFieldValue = entry.getValue();
+ if (UtilValidate.isNotEmpty(currentFieldName)
&& !pkFields.contains(currentFieldName)) {
+ if (modelEntity.isField(currentFieldName))
{
+ if
(UtilValidate.isNotEmpty(currentFieldValue)) {
+ ModelField modelField =
modelEntity.getField(currentFieldName);
+ String type = modelField.getType();
+ if (type != null &&
"blob".equals(type)) {
+ byte[] binData =
Base64.base64Decode(((String) currentFieldValue).getBytes());
+
currentValue.setBytes(currentFieldName, binData);
+ } else {
+
currentValue.setString(currentFieldName, currentFieldValue.toString());
+ }
+
absentFields.remove(currentFieldName);
+ }
+ } else {
+ Debug.logWarning("Ignoring invalid
field name [" + currentFieldName + "] found for the entity: "
+ + currentValue.getEntityName()
+ " with value=" + currentFieldValue.toString(), module);
+ }
+ }
+ }
+ if (absentFields != null) {
+ for (String fieldName : absentFields) {
+ currentValue.set(fieldName, null);
+ }
+ }
+ if (exist) {
+ this.valuesToUpdate.add(currentValue);
+ } else {
+ // Not sure about this!
+ //if (this.useTryInsertMethod &&
!this.checkDataOnly) {
+ // currentValue.create();
+ //} else {
+ this.valuesToCreate.add(currentValue);
+ //}
+ }
+ if (this.maintainTxStamps) {
+ currentValue.setIsFromEntitySync(true);
+ }
+ this.numberReplaced++;
+ }
+ } catch (Exception e) {
+ if (continueOnFail) {
+ Debug.logError(e, module);
+ } else {
+ throw new IOException(e);
+ }
+ }
+ }
+ }
+ }
+ return this.numberReplaced;
+ }
+
+ private long delete(JSONObject jsonObject) throws IOException {
+ Iterator iterator = jsonObject.keySet().iterator();
+ while (iterator.hasNext()) {
+ String key = iterator.next().toString();
+ Object value = jsonObject.get(key);
+ if (UtilValidate.isNotEmpty(value)) {
+ List<Map<String, Object>> genericMapList =
this.iterateJsonEntityData(value);
+ for (Map<String, Object> keyValPair : genericMapList) {
+ try {
+ ModelEntity modelEntity =
this.delegator.getModelEntity(key);
+ GenericValue currentValue = delegator.makeValue(key,
keyValPair);
+ if (this.maintainTxStamps) {
+ currentValue.setIsFromEntitySync(true);
+ }
+ GenericHelper helper = delegator.getEntityHelper(key);
+ if (currentValue != null) {
+ boolean exist = true;
+ if (currentValue.containsPrimaryKey()) {
+ try {
+
helper.findByPrimaryKey(currentValue.getPrimaryKey());
+ } catch (GenericEntityNotFoundException e) {
+ exist = false;
+ }
+ }
+ if (exist) {
+ if (this.useTryInsertMethod &&
!this.checkDataOnly) {
+ currentValue.remove();
+ } else {
+ this.valuesToDelete.add(currentValue);
+ }
+ this.numberDeleted++;
+ }//if pk exist ignore it.
+ }
+ } catch (Exception e) {
+ if (continueOnFail) {
+ Debug.logError(e, module);
+ } else {
+ throw new IOException(e);
+ }
+ }
+ }
+ }
+ }
+ return this.numberDeleted;
+ }
+
+ private long action(Object jsonData, String actionName) throws IOException
{
+ java.lang.reflect.Method method;
+ try {
+ method = this.getClass().getDeclaredMethod(actionName,
JSONObject.class);
+ if (jsonData instanceof JSONArray) {
+ JSONArray jsonArray = (JSONArray) jsonData;
+ int length = jsonArray.length();
+ for (int jsonIndex = 0; jsonIndex < length; ++jsonIndex) {
+ JSONObject jsonObject = jsonArray.getJSONObject(jsonIndex);
+ method.invoke(this, jsonObject);
+ }
+ } else if (jsonData instanceof JSONObject) {
+ method.invoke(this, (JSONObject) jsonData);
+ }
+ } catch (Exception e) {
+ throw new IOException(e);
+ }
+ return this.numberCreated;
+ }
+
+ private long writeValues() {
+ this.numberRead = 0L;
+
+ try {
+ boolean beganTransaction = false;
+ if (this.transactionTimeout > -1) {
+ beganTransaction =
TransactionUtil.begin(this.transactionTimeout);
+ Debug.logImportant("Transaction Timeout set to " +
this.transactionTimeout / 3600 + " hours ("
+ + this.transactionTimeout + " seconds)", module);
+ }
+
+ try {
+ if (!this.valuesToCreate.isEmpty()) {
+ this.writeValues(this.valuesToCreate);
+ numberRead = numberRead + this.valuesToCreate.size();
+ this.valuesToCreate.clear();
+ }
+
+ if (!this.valuesToDelete.isEmpty()) {
+ this.delegator.removeAll(this.valuesToDelete);
+ numberRead = numberRead + this.valuesToDelete.size();
+ this.valuesToDelete.clear();
+ }
+ if (!this.valuesToUpdate.isEmpty()) {
+ this.writeValues(this.valuesToUpdate);
+ numberRead = numberRead + this.valuesToUpdate.size();
+ this.valuesToUpdate.clear();
+ }
+
+ TransactionUtil.commit(beganTransaction);
+ } catch (IllegalArgumentException | GenericEntityException e1) {
+ String errMsg = "An error occurred saving the data, rolling
back transaction (" + beganTransaction
+ + ")";
+ Debug.logError(e1, errMsg, module);
+ TransactionUtil.rollback(beganTransaction, errMsg, e1);
+ }
+ } catch (GenericTransactionException e) {
+ Debug.logError(e, "A transaction error occurred reading data",
module);
+ }
+
+ if (Debug.verboseOn()) {
+ Debug.logVerbose(" Detail created : " + this.numberCreated + ",
skipped : " + this.numberSkipped
+ + ", updated : " + this.numberUpdated + ", replaced : " +
this.numberReplaced + ", deleted : "
+ + this.numberDeleted, module);
+ }
+
+ return this.numberRead;
+ }
+
+ private void writeValues(List<GenericValue> valuesToWrite) throws
GenericEntityException {
+ if (this.checkDataOnly) {
+ EntityDataAssert.checkValueList(valuesToWrite, this.delegator,
this.getMessageList());
+ } else {
+ this.delegator.storeAll(valuesToWrite, new
EntityStoreOptions(this.createDummyFks));
+ }
+
+ }
+}
Propchange:
ofbiz/ofbiz-framework/trunk/framework/entity/src/main/java/org/apache/ofbiz/entity/util/EntityJsonReader.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
ofbiz/ofbiz-framework/trunk/framework/entity/src/main/java/org/apache/ofbiz/entity/util/EntityJsonReader.java
------------------------------------------------------------------------------
svn:keywords = Date Rev Author URL Id
Propchange:
ofbiz/ofbiz-framework/trunk/framework/entity/src/main/java/org/apache/ofbiz/entity/util/EntityJsonReader.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Modified:
ofbiz/ofbiz-framework/trunk/framework/webtools/config/WebtoolsUiLabels.xml
URL:
http://svn.apache.org/viewvc/ofbiz/ofbiz-framework/trunk/framework/webtools/config/WebtoolsUiLabels.xml?rev=1862206&r1=1862205&r2=1862206&view=diff
==============================================================================
--- ofbiz/ofbiz-framework/trunk/framework/webtools/config/WebtoolsUiLabels.xml
(original)
+++ ofbiz/ofbiz-framework/trunk/framework/webtools/config/WebtoolsUiLabels.xml
Thu Jun 27 11:49:22 2019
@@ -98,6 +98,15 @@
<value
xml:lang="zh">没ææå®çæ件å/ç½åæå®æ´çXMLææ¡£ï¼ä»ä¹ä¹ä¸åã</value>
<value
xml:lang="zh-TW">æ²ææå®çæªæ¡å/網åæå®æ´çXMLæª,ä»éº¼ä¹ä¸å.</value>
</property>
+ <property key="EntityImportNoJsonFileSpecified">
+ <value xml:lang="en">No filename/URL or complete JSON document
specified, doing nothing.</value>
+ <value xml:lang="fr">Pas de fichier, URL ou flux JSON fournit, aucune
action réalisée.</value>
+ <value xml:lang="it">Nessun nome file/URL o documento JSON completo
specificato, nientre verrà fatto.</value>
+ <value xml:lang="ja">ãã¡ã¤ã«å/URLã¾ãã¯å®å
¨ãªJSONææ¸ãæå®ããã¦ãã¾ãããå¦çãè¡ãã¾ããã</value>
+ <value xml:lang="vi">Không Táºp tin/URL hoặc tà i liá»u JSON hoÃ
n chá»nh nà o Äược xác Äá»nh nên há» thá»ng sẽ không là m gì
cả.</value>
+ <value
xml:lang="zh">没ææå®çæ件å/ç½åæå®æ´çJSONææ¡£ï¼ä»ä¹ä¹ä¸åã</value>
+ <value
xml:lang="zh-TW">æ²ææå®çæªæ¡å/網åæå®æ´çJSONæª,ä»éº¼ä¹ä¸å.</value>
+ </property>
<property key="EntityImportNumberOfEntityToBeProcessed">
<value xml:lang="en">Got ${numberRead} entities from
${fileName}</value>
<value xml:lang="fr">Chargement de ${numberRead} entités depuis
${fileName}</value>
@@ -116,6 +125,15 @@
<value
xml:lang="zh">解æå®ä½XMLæ件æ¶åºéï¼${errorString}</value>
<value
xml:lang="zh-TW">解æè³æ實é«XMLæªæåºé¯:${errorString}</value>
</property>
+ <property key="EntityImportJsonParsingError">
+ <value xml:lang="en">ERROR parsing Entity Json file:
${errorString}</value>
+ <value xml:lang="fr">ERREUR dans l'analyse de l'JSON :
${errorString}</value>
+ <value xml:lang="it">ERRORE di parsing file entità JSON:
${errorString}</value>
+ <value
xml:lang="ja">ã¨ã³ãã£ãã£JSONãã¡ã¤ã«ãã¼ã¹æã«ã¨ã©ã¼:
${errorString}</value>
+ <value xml:lang="vi">Lá»I khi phân tÃch táºp tin JSON Thá»±c
thá»: ${errorString}</value>
+ <value
xml:lang="zh">解æå®ä½JSONæ件æ¶åºéï¼${errorString}</value>
+ <value
xml:lang="zh-TW">解æè³æ實é«JSONæªæåºé¯:${errorString}</value>
+ </property>
<property key="EntityImportPassedFile">
<value xml:lang="en">Pass ${passes} complete</value>
<value xml:lang="fr">Passe ${passes} complete</value>
@@ -513,6 +531,32 @@
<value xml:lang="zh">XMLæ°æ®å¯¼åºå
¨é¨</value>
<value xml:lang="zh-TW">XMLè³æå¯åºå
¨é¨</value>
</property>
+ <property key="PageTitleEntityExportJson">
+ <value xml:lang="de">JSON-Daten exportieren</value>
+ <value xml:lang="en">JSON Data Export</value>
+ <value xml:lang="fr">Export de données JSON</value>
+ <value xml:lang="it">Esporta dati in JSON</value>
+ <value xml:lang="ja">JSONãã¼ã¿ã¨ã¯ã¹ãã¼ã</value>
+ <value xml:lang="pt">Exportação de dados JSON</value>
+ <value xml:lang="ro">Exporta Date in JSON</value>
+ <value xml:lang="th">สà¹à¸à¸à¸à¸à¸à¹à¸à¸¡à¸¹à¸¥ json</value>
+ <value xml:lang="vi">Kết xuất dữ liá»u JSON</value>
+ <value xml:lang="zh">JSONæ°æ®å¯¼åº</value>
+ <value xml:lang="zh-TW">JSONè³æå¯åº</value>
+ </property>
+ <property key="PageTitleEntityExportAllJson">
+ <value xml:lang="de">Alle JSON-Daten exportieren</value>
+ <value xml:lang="en">JSON Data Export All</value>
+ <value xml:lang="fr">Exporter toutes les données JSON</value>
+ <value xml:lang="it">Esporta tutti i dati in JSON</value>
+ <value
xml:lang="ja">JSONãã¼ã¿ããã¹ã¦ã¨ã¯ã¹ãã¼ã</value>
+ <value xml:lang="pt">Exportação de todos os dados JSON</value>
+ <value xml:lang="ro">Exporta Toate Datele in JSON</value>
+ <value xml:lang="th">สà¹à¸à¸à¸à¸à¸à¹à¸à¸¡à¸¹à¸¥ JSON
à¸à¸±à¹à¸à¸«à¸¡à¸</value>
+ <value xml:lang="vi">Kết xuất tất cả dữ liá»u JSON</value>
+ <value xml:lang="zh">JSONæ°æ®å¯¼åºå
¨é¨</value>
+ <value xml:lang="zh-TW">JSONè³æå¯åºå
¨é¨</value>
+ </property>
<property key="PageTitleEntityImport">
<value xml:lang="de">XML-Daten importieren</value>
<value xml:lang="en">XML Data Import</value>
@@ -539,6 +583,32 @@
<value xml:lang="zh">XMLæ°æ®å¯¼å
¥ç®å½ </value>
<value xml:lang="zh-TW">XMLè³æå¯å
¥ç®é </value>
</property>
+ <property key="PageTitleEntityImportJson">
+ <value xml:lang="de">JSON-Daten importieren</value>
+ <value xml:lang="en">JSON Data Import</value>
+ <value xml:lang="fr">Import de données JSON</value>
+ <value xml:lang="it">Importa dati da JSON</value>
+ <value xml:lang="ja">JSONãã¼ã¿ã¤ã³ãã¼ã</value>
+ <value xml:lang="pt">Importar dados JSON</value>
+ <value xml:lang="ro">Importa Datele din JSON</value>
+ <value xml:lang="th">à¸à¸³à¹à¸à¹à¸²à¸à¹à¸à¸¡à¸¹à¸¥ json</value>
+ <value xml:lang="vi">Nháºp khẩu dữ liá»u JSON</value>
+ <value xml:lang="zh">JSONæ°æ®å¯¼å
¥</value>
+ <value xml:lang="zh-TW">JSONè³æå¯å
¥</value>
+ </property>
+ <property key="PageTitleEntityImportDirJson">
+ <value xml:lang="de">JSON Datenimport aus Verzeichnis</value>
+ <value xml:lang="en">JSON Data Import Dir</value>
+ <value xml:lang="fr">Import de données JSON depuis un
répertoire</value>
+ <value xml:lang="it">Importa dati JSON in directory</value>
+ <value
xml:lang="ja">JSONãã¼ã¿ã¤ã³ãã¼ããã£ã¬ã¯ããª</value>
+ <value xml:lang="pt">Importar dados JSON em diretório</value>
+ <value xml:lang="ro">Importa Datele din JSON in Directory</value>
+ <value xml:lang="th">à¸à¸³à¹à¸à¹à¸²à¸à¹à¸à¸¡à¸¹à¸¥ json à¹à¸
Directory</value>
+ <value xml:lang="vi">ThÆ° mục nháºp khẩu JSON</value>
+ <value xml:lang="zh">JSONæ°æ®å¯¼å
¥ç®å½ </value>
+ <value xml:lang="zh-TW">JSONè³æå¯å
¥ç®é </value>
+ </property>
<property key="PageTitleEntityImportReaders">
<value xml:lang="de">Leser für XML Datenimport</value>
<value xml:lang="en">XML Data Import Readers</value>
@@ -1220,6 +1290,19 @@
<value xml:lang="zh">å®æXMLææ¡£ (æ ¹æ ç¾:
entity-engine-xml)</value>
<value xml:lang="zh-TW">å®æXMLæª (æ ¹æ¨ç°½:
entity-engine-xml)</value>
</property>
+ <property key="WebtoolsCompleteJsonData">
+ <value xml:lang="de">Vollständiges JSON dokument</value>
+ <value xml:lang="en">Complete JSON data</value>
+ <value xml:lang="fr">Compléter le data JSON</value>
+ <value xml:lang="it">Documento JSON</value>
+ <value xml:lang="ja">JSONããã¥ã¡ã³ããå®äºãã</value>
+ <value xml:lang="pt">Documento JSON completo</value>
+ <value xml:lang="ro">Completeaza documentul JSON</value>
+ <value xml:lang="th">à¹à¸à¸à¸ªà¸²à¸£ JSON
à¹à¸ªà¸£à¹à¸à¹à¸£à¸µà¸¢à¸à¸£à¹à¸à¸¢à¹à¸¥à¹à¸§</value>
+ <value xml:lang="vi">Hoà n thà nh tà i liá»u JSON</value>
+ <value xml:lang="zh">å®æJSONææ¡£</value>
+ <value xml:lang="zh-TW">å®æJSONæª</value>
+ </property>
<property key="WebtoolsComponentsLoaded">
<value xml:lang="de">Komponenten geladen</value>
<value xml:lang="en">Loaded Components</value>
@@ -1997,6 +2080,18 @@
<value xml:lang="zh">å®ä½XMLå·¥å
·</value>
<value xml:lang="zh-TW">è³æ實é«XMLå·¥å
·</value>
</property>
+ <property key="WebtoolsEntityJSONTools">
+ <value xml:lang="de">Entität JSON Tools</value>
+ <value xml:lang="en">Entity JSON Tools</value>
+ <value xml:lang="fr">Outils JSON d'entité</value>
+ <value xml:lang="it">Strumenti JSON per entità </value>
+ <value xml:lang="ja">ã¨ã³ãã£ãã£JSONãã¼ã«</value>
+ <value xml:lang="ro">Instrumente pentru Entitatea JSON</value>
+ <value xml:lang="th">à¹à¸à¸£à¸·à¹à¸à¸à¸¡à¸·à¸ Entity JSON
</value>
+ <value xml:lang="vi">Công cụ JSON Thá»±c thá»</value>
+ <value xml:lang="zh">å®ä½JSONå·¥å
·</value>
+ <value xml:lang="zh-TW">è³æ實é«XMLå·¥å
·</value>
+ </property>
<property key="WebtoolsEnvName">
<value xml:lang="de">Umgebungsname</value>
<value xml:lang="en">Env Name</value>
@@ -2186,6 +2281,19 @@
<value xml:lang="zh">ä»æ°æ®æºå¯¼åºXML</value>
<value xml:lang="zh-TW">å¾è³ææºå¯åºXML</value>
</property>
+ <property key="WebtoolsExportJSONFromDataSource">
+ <value xml:lang="de">JSON Export aus der Datenquelle</value>
+ <value xml:lang="en">JSON Export from DataSource(s)</value>
+ <value xml:lang="fr">Export JSON depuis les sources de données</value>
+ <value xml:lang="it">Esportazione JSON da Datasource</value>
+ <value
xml:lang="ja">ãã¼ã¿ã½ã¼ã¹ããJSONãã¨ã¯ã¹ãã¼ã</value>
+ <value xml:lang="pt">Exportar de JSON DataSource(s)</value>
+ <value xml:lang="ro">Exporta Sursa Date in JSON</value>
+ <value xml:lang="th">JSON
à¸à¸µà¹à¸¡à¸²à¸à¸²à¸à¹à¸«à¸¥à¹à¸à¸à¹à¸à¸¡à¸¹à¸¥</value>
+ <value xml:lang="vi">Kết xuất JSON từ nguá»n dữ liá»u</value>
+ <value xml:lang="zh">ä»æ°æ®æºå¯¼åºJSON</value>
+ <value xml:lang="zh-TW">å¾è³ææºå¯åºJSON</value>
+ </property>
<property key="WebtoolsExportable">
<value xml:lang="de">Exportierbar</value>
<value xml:lang="en">Exportable</value>
@@ -2640,6 +2748,19 @@
<value xml:lang="zh">æXML导å
¥å°æ°æ®æº</value>
<value xml:lang="zh-TW">æXMLå¯å
¥å°è³ææº</value>
</property>
+ <property key="WebtoolsJsonImportToDataSource">
+ <value xml:lang="de">JSON-Import in DataSource(n)</value>
+ <value xml:lang="en">JSON Import to DataSource(s)</value>
+ <value xml:lang="fr">Import JSON vers la source de données</value>
+ <value xml:lang="it">Importazione JSON in Datasource</value>
+ <value
xml:lang="ja">ãã¼ã¿ã½ã¼ã¹ã«JSONãã¤ã³ãã¼ã</value>
+ <value xml:lang="pt">Importar JSON para DataSource(s)</value>
+ <value xml:lang="ro">Importa Sursa de Date din JSON</value>
+ <value xml:lang="th">à¸à¸³à¹à¸à¹à¸² JSON
à¹à¸à¸¢à¸±à¸à¹à¸«à¸¥à¹à¸à¸à¹à¸à¸¡à¸¹à¸¥</value>
+ <value xml:lang="vi">Nháºp khẩu JSON từ nguá»n dữ
liá»u</value>
+ <value xml:lang="zh">æJSON导å
¥å°æ°æ®æº</value>
+ <value xml:lang="zh-TW">æJSONå¯å
¥å°è³ææº</value>
+ </property>
<property key="WebtoolsImportantLogLevel">
<value xml:lang="de">Wichtig</value>
<value xml:lang="en">Important</value>
@@ -5942,7 +6063,7 @@
<property key="WebtoolsXMLExportInfo">
<value xml:lang="de">Hier Seite können Daten aus der Datenbank
exportiert werden. Die exportierten Dokumente werden in einem XML-root-tag
"<entity-engine-xml>" enthalten sein. Es wird für jede Entität in dem
für diese webapp konfigurierten Delegator eine eigene Datei erstellt.</value>
<value xml:lang="en">This page can be used to export data from the
database. The exported documents will have a root tag of
"<entity-engine-xml>". There will be one file for each Entity in the
configured delegator for this webapp.</value>
- <value xml:lang="fr">Cette page peut être utilisée pour exporter des
données depuis la base. Les documents exportés auront une balise de racine de
"<entity-engine-xml>". Il y aura un dossier pour chaque entité dans le
delegator configuré pour cette webapp.</value>
+ <value xml:lang="fr">Cette page peut être utilisée pour exporter des
données depuis la base. Les documents exportés auront une balise de racine de
"<entity-engine-xml>". Il y aura un fichier créé pour chaque entité
dans le delegator configuré pour cette webapp.</value>
<value xml:lang="it">Questa pagina può essere usata per esportare i
dati dal database. I documenti esportati avranno un root tag
"<entity-engine-xml>". C'è un file per ogni Entità nel delegator
configurato per questa applicazione web.</value>
<value
xml:lang="ja">ãã®ãã¼ã¸ã§ãã¼ã¿ãã¼ã¹ãããã¼ã¿ãã¨ã¯ã¹ãã¼ããããã¨ãã§ãã¾ããã¨ã¯ã¹ãã¼ãããããã¥ã¡ã³ãã«ã¯"<entity-engine-xml>"ã«ã¼ãã¿ã°ãããã¾ããWebã¢ããªã±ã¼ã·ã§ã³ã«è¨å®ãããããªã²ã¼ã¿ã®ä¸ã®ããããã®ã¨ã³ãã£ãã£ã«å¯¾ãã¦ï¼ã¤ã®ãã¡ã¤ã«ãä½æããã¾ãã</value>
<value xml:lang="pt">Esta página pode ser utilizado para exportar
dados do banco de dados. Os documentos de exportação terão uma tag
raiz de " <entity-engine-xml>". Haverá um arquivo para cada entidade
do delegator configurado para essa webapp.</value>
@@ -5952,6 +6073,43 @@
<value xml:lang="zh">æ¬é¡µé¢ç¨äºä»æ°æ®åºå¯¼åºæ°æ®
导åºçææ¡£ä¼æä¸ä¸ª"<entity-engine-xml>"çæ ¹æ
ç¾å¨ä¸ºè¿ä¸ªåºç¨é
ç½®ç代表ä¸ï¼ä¼å¯¹æ¯ä¸ªå®ä½æä¸ä¸ªæ件ã</value>
<value xml:lang="zh-TW">æ¬é é¢ç¨æ¼å¾è³æ庫å¯åºè³æ
å¯åºçæªææä¸å"<entity-engine-xml>"çæ
¹æ¨ç°½å¨çºéåæç¨é
ç½®ç代表ä¸,æå°æ¯åè³æ實é«æä¸åæª.</entity-engine-xml></value>
</property>
+ <property key="WebtoolsWroteNRecordsToJSONFile">
+ <value xml:lang="de">Es wurden ${numberWritten} Datensätze in die
Datei ${parameters.filename} geschrieben.</value>
+ <value xml:lang="en">Wrote ${numberWritten} records to JSON file
${parameters.filename}.</value>
+ <value xml:lang="fr">Ecrire ${numberWritten} les enregistrements dans
le fichier JSON ${parameters.filename}.</value>
+ <value xml:lang="it">Scritti ${numberWritten} records su file JSON
${parameters.filename}.</value>
+ <value xml:lang="ja">${numberWritten}
ã¬ã³ã¼ãããJSONãã¡ã¤ã« ${parameters.filename}
ã«æ¸ãåºãã¾ããã</value>
+ <value xml:lang="pt">Escreveu ${numberWritten} registros para o
arquivo JSON ${parameters.filename}.</value>
+ <value xml:lang="th">à¹à¸à¸µà¸¢à¸ ${numberWritten}
à¸à¸±à¸à¸à¸¶à¸à¸¡à¸¹à¸¥ XML à¹à¸à¸¥à¹ ${parameters.filename}.</value>
+ <value xml:lang="vi">Äã ghi ${numberWritten} bản ghi tá»i táºp
tin JSON ${parameters.filename}.</value>
+ <value
xml:lang="zh">æ${numberWritten}个记å½åå°JSONæ件${parameters.filename}ã</value>
+ <value
xml:lang="zh-TW">æ${numberWritten}åè¨é寫å°JSONæª${parameters.filename}.</value>
+ </property>
+ <property key="WebtoolsWroteJSONForAllDataIn">
+ <value xml:lang="de">Es wurde JSON für alle Daten in
${numberofEntities} Entitäten geschrieben.</value>
+ <value xml:lang="en">Wrote JSON for all data in ${numberOfEntities}
entities.</value>
+ <value xml:lang="fr">Ecrire JSON pour toute les donnée inclues
${numberOfEntities} Entités.</value>
+ <value xml:lang="it">Scritti JSON per tutti i dati in
${numberOfEntities} entità .</value>
+ <value xml:lang="ja">${numberOfEntities}
ã¨ã³ãã£ãã£ã®ãã¹ã¦ã®ãã¼ã¿ãXMLãã¡ã¤ã«ã«æ¸ãåºãã¾ããã</value>
+ <value xml:lang="pt">Escreveu JSON para todos os dados em
${numberOfEntities} entidades.</value>
+ <value xml:lang="th">à¹à¸à¸µà¸¢à¸ JSON
สำหรัà¸à¸à¹à¸à¸¡à¸¹à¸¥à¸à¸±à¹à¸à¸«à¸¡à¸à¹à¸
${numberOfEntities} entities.</value>
+ <value xml:lang="vi">Äã ghi JSON cho tất cả dữ liá»u trong
${numberOfEntities} Thá»±c thá».</value>
+ <value xml:lang="zh">为${numberOfEntities}个å®ä½ä¸çå
¨é¨æ°æ®åå°JSONã</value>
+ <value xml:lang="zh-TW">çº${numberOfEntities}åè³æ實é«ä¸çå
¨é¨è³æ寫å°JSON.</value>
+ </property>
+ <property key="WebtoolsJSONExportInfo">
+ <value xml:lang="de">Hier Seite können Daten aus der Datenbank
exportiert werden. Es wird für jede Entität in dem für diese webapp
konfigurierten Delegator eine eigene Datei erstellt.</value>
+ <value xml:lang="en">This page can be used to export data from the
database. There will be one file for each Entity in the configured delegator
for this webapp.</value>
+ <value xml:lang="fr">Cette page peut être utilisée pour exporter des
données depuis la base. Il y aura un fichier créé pour chaque entité dans
le delegator configuré pour cette webapp.</value>
+ <value xml:lang="it">Questa pagina può essere usata per esportare i
dati dal database. C'è un file per ogni Entità nel delegator configurato per
questa applicazione web.</value>
+ <value
xml:lang="ja">ãã®ãã¼ã¸ã§ãã¼ã¿ãã¼ã¹ãããã¼ã¿ãã¨ã¯ã¹ãã¼ããããã¨ãã§ãã¾ããWebã¢ããªã±ã¼ã·ã§ã³ã«è¨å®ãããããªã²ã¼ã¿ã®ä¸ã®ããããã®ã¨ã³ãã£ãã£ã«å¯¾ãã¦ï¼ã¤ã®ãã¡ã¤ã«ãä½æããã¾ãã</value>
+ <value xml:lang="pt">Esta página pode ser utilizado para exportar
dados do banco de dados. Haverá um arquivo para cada entidade do delegator
configurado para essa webapp.</value>
+ <value xml:lang="ro">Aceasta pagina poate fi folosita pentru
exportarea datelor din database. Exista un file pentru orice Entitate din
delegatorul configurat pentru aceasta aplicatie web.</value>
+ <value
xml:lang="th">หà¸à¹à¸²à¸à¸µà¹à¹à¸à¹à¸à¸²à¸£à¸ªà¹à¸à¸à¸à¸à¸à¹à¸à¸¡à¸¹à¸¥à¸à¸²à¸à¸à¸²à¸à¸à¹à¸à¸¡à¸¹à¸¥à¸à¸²à¸£à¸ªà¹
มี 1 à¹à¸à¸¥à¹à¸ªà¸³à¸«à¸£à¸±à¸à¸à¸±à¸§à¸à¸¢à¹à¸²à¸ Entity
à¹à¸à¸à¸²à¸£à¸ªà¸£à¹à¸²à¸à¸à¸±à¸§à¹à¸à¸à¸ªà¸³à¸«à¸£à¸±à¸à¹à¸à¸£à¹à¸à¸£à¸¡à¸à¸£à¸°à¸¢à¸¸à¸à¸à¹à¸à¸µà¹</value>
+ <value xml:lang="vi">Giao diá»n bạn Äang sá» dụng cung cấp
chức nÄng Kết xuất dữ liá»u từ CÆ¡ sá» dữ liá»u.( có 01 Táºp
tin vá»i má»i Thá»±c thá» của Ứng dụng nà y)</value>
+ <value xml:lang="zh">æ¬é¡µé¢ç¨äºä»æ°æ®åºå¯¼åºæ°æ® çæ ¹æ
ç¾å¨ä¸ºè¿ä¸ªåºç¨é
ç½®ç代表ä¸ï¼ä¼å¯¹æ¯ä¸ªå®ä½æä¸ä¸ªæ件ã</value>
+ <value xml:lang="zh-TW">æ¬é é¢ç¨æ¼å¾è³æ庫å¯åºè³æ çæ
¹æ¨ç°½å¨çºéåæç¨é
ç½®ç代表ä¸,æå°æ¯åè³æ實é«æä¸åæª.</value>
+ </property>
<property key="WebtoolsXMLImportInfo">
<value xml:lang="de">Hier können zuvor exportierte Entitäten XML
Dateien wieder in die Datenbank importiert werden. Diese Dokumente haben eine
XML-root-tag "<entity-engine-xml>".</value>
<value xml:lang="en">This page can be used to import exported Entity
Engine XML documents. These documents all have a root tag of
"<entity-engine-xml>".</value>
@@ -5965,6 +6123,19 @@
<value xml:lang="zh">æ¬é¡µé¢ç¨äºå¯¼å
¥å¯¼åºçå®ä½å¼æXMLææ¡£ãè¿äºææ¡£é½æä¸ä¸ªæ ¹æ ç¾
"<entity-engine-xml>".</value>
<value xml:lang="zh-TW">æ¬é é¢ç¨æ¼å¯å
¥å¯åºçè³æ實é«å¼æXMLæª.éäºæªé½æä¸åæ ¹æ¨ç°½
"<entity-engine-xml>".</entity-engine-xml></value>
</property>
+ <property key="WebtoolsJSONImportInfo">
+ <value xml:lang="de">Hier können zuvor exportierte Entitäten JSON
Dateien wieder in die Datenbank importiert werden.</value>
+ <value xml:lang="en">This page can be used to import exported Entity
Engine JSON data.</value>
+ <value xml:lang="fr">Cette page peut être utilisée pour importer des
documents JSON exportés par le moteur d'entité.".</value>
+ <value xml:lang="it">Questa pagina può essere usata per importare
documenti JSON contenenti export di Entita'.</value>
+ <value
xml:lang="ja">ãã®ãã¼ã¸ã§ã¨ã¯ã¹ãã¼ããããã¨ã³ãã£ãã£ã¨ã³ã¸ã³JSONããã¥ã¡ã³ããã¤ã³ãã¼ããããã¨ãã§ãã¾ãã</value>
+ <value xml:lang="pt">Esta página pode ser utilizado para
importação e exportação de documentos JSON do Engine de
Entidades.</value>
+ <value xml:lang="ro">Aceasta pagina nu poate fi folosita pentru
importarea exportarea documentelor JSON de Entity Engine.</value>
+ <value
xml:lang="th">หà¸à¹à¸²à¸à¸µà¹à¹à¸à¹à¸à¸²à¸£à¸à¸³à¹à¸à¹à¸²à¸à¹à¸à¸¡à¸¹à¸¥à¸à¸µà¹à¸¡à¸µà¸à¸²à¸£à¸ªà¹à¸à¸à¸à¸à¹à¸à¸à¸à¸´à¸à¸µà¹à¹à¸à¸à¸à¸´à¸à¹à¸à¸à¸ªà¸²à¸£
JSON à¹à¸à¸¢à¹à¸à¹à¸à¸³à¸ªà¸±à¹à¸</value>
+ <value xml:lang="vi">Giao diá»n bạn Äang sá» dụng cung cấp
chức nÄng Nháºp khẩu dữ liá»u từ các Tà i liá»u Thá»±c thá»
JSON.</value>
+ <value xml:lang="zh">æ¬é¡µé¢ç¨äºå¯¼å
¥å¯¼åºçå®ä½å¼æJSONææ¡£ã</value>
+ <value xml:lang="zh-TW">æ¬é é¢ç¨æ¼å¯å
¥å¯åºçè³æ實é«å¼æJSONæª</value>
+ </property>
<property key="WebtoolsYouMayCreateAnEntity">
<value xml:lang="de">You may create an Entity ${entityName} by
entering the values you want, and clicking Create.</value>
<value xml:lang="en">You may create an Entity ${entityName} by
entering the values you want, and clicking Create.</value>
Added:
ofbiz/ofbiz-framework/trunk/framework/webtools/groovyScripts/entity/JsonDsDump.groovy
URL:
http://svn.apache.org/viewvc/ofbiz/ofbiz-framework/trunk/framework/webtools/groovyScripts/entity/JsonDsDump.groovy?rev=1862206&view=auto
==============================================================================
---
ofbiz/ofbiz-framework/trunk/framework/webtools/groovyScripts/entity/JsonDsDump.groovy
(added)
+++
ofbiz/ofbiz-framework/trunk/framework/webtools/groovyScripts/entity/JsonDsDump.groovy
Thu Jun 27 11:49:22 2019
@@ -0,0 +1,365 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import java.util.*
+import java.io.*
+import org.apache.ofbiz.base.util.*
+import org.apache.ofbiz.entity.model.*
+import org.apache.ofbiz.entity.util.*
+import org.apache.ofbiz.entity.transaction.*
+import org.apache.ofbiz.entity.condition.*
+
+outpath = parameters.outpath
+filename = parameters.filename
+maxRecStr = parameters.maxrecords
+entitySyncId = parameters.entitySyncId
+passedEntityNames = null
+if (parameters.entityName) passedEntityNames = parameters.entityName
instanceof Collection ? parameters.entityName as TreeSet :
[parameters.entityName] as TreeSet
+
+// get the max records per file setting and convert to a int
+maxRecordsPerFile = 0
+if (maxRecStr) {
+ try {
+ maxRecordsPerFile = Integer.parseInt(maxRecStr)
+ }
+ catch (Exception e) {
+ }
+}
+
+preConfiguredSetName = parameters.preConfiguredSetName
+if ("Product1".equals(preConfiguredSetName)) {
+ passedEntityNames = new LinkedHashSet()
+ passedEntityNames.add("DataResource")
+ passedEntityNames.add("Facility")
+ passedEntityNames.add("ProdCatalog")
+ passedEntityNames.add("Product")
+ passedEntityNames.add("ProductCategory")
+ passedEntityNames.add("ProductFeatureCategory")
+ passedEntityNames.add("ProductFeatureType")
+ passedEntityNames.add("ProductPriceRule")
+ passedEntityNames.add("ProductPromo")
+} else if ("Product2".equals(preConfiguredSetName)) {
+ passedEntityNames = new LinkedHashSet()
+ passedEntityNames.add("Content")
+ passedEntityNames.add("ElectronicText")
+ passedEntityNames.add("FacilityLocation")
+ passedEntityNames.add("ProdCatalogCategory")
+ passedEntityNames.add("ProdCatalogRole")
+ passedEntityNames.add("ProductAssoc")
+ passedEntityNames.add("ProductAttribute")
+ passedEntityNames.add("ProductCategoryMember")
+ passedEntityNames.add("ProductCategoryRollup")
+ passedEntityNames.add("ProductFacility")
+ passedEntityNames.add("ProductFeature")
+ passedEntityNames.add("ProductFeatureCategoryAppl")
+ passedEntityNames.add("ProductKeyword")
+ passedEntityNames.add("ProductPrice")
+ passedEntityNames.add("ProductPriceAction")
+ passedEntityNames.add("ProductPriceCond")
+ passedEntityNames.add("ProductPromoCode")
+ passedEntityNames.add("ProductPromoCategory")
+ passedEntityNames.add("ProductPromoProduct")
+ passedEntityNames.add("ProductPromoRule")
+} else if ("Product3".equals(preConfiguredSetName)) {
+ passedEntityNames = new LinkedHashSet()
+ passedEntityNames.add("ProdCatalogInvFacility")
+ passedEntityNames.add("ProductContent")
+ passedEntityNames.add("ProductFacilityLocation")
+ passedEntityNames.add("ProductFeatureAppl")
+ passedEntityNames.add("ProductFeatureDataResource")
+ passedEntityNames.add("ProductFeatureGroup")
+ passedEntityNames.add("ProductPriceChange")
+ passedEntityNames.add("ProductPromoAction")
+ passedEntityNames.add("ProductPromoCodeEmail")
+ passedEntityNames.add("ProductPromoCodeParty")
+ passedEntityNames.add("ProductPromoCond")
+} else if ("Product4".equals(preConfiguredSetName)) {
+ passedEntityNames = new LinkedHashSet()
+ passedEntityNames.add("InventoryItem")
+ passedEntityNames.add("ProductFeatureCatGrpAppl")
+ passedEntityNames.add("ProductFeatureGroupAppl")
+} else if ("CatalogExport".equals(preConfiguredSetName)) {
+ passedEntityNames = new LinkedHashSet()
+ passedEntityNames.add("ProdCatalogCategoryType")
+ passedEntityNames.add("ProdCatalog")
+ passedEntityNames.add("ProductCategoryType")
+ passedEntityNames.add("ProductCategory")
+ passedEntityNames.add("ProductCategoryRollup")
+ passedEntityNames.add("ProdCatalogCategory")
+ passedEntityNames.add("ProductFeatureType")
+ passedEntityNames.add("ProductFeatureCategory")
+
+ passedEntityNames.add("DataResource")
+ passedEntityNames.add("Content")
+ passedEntityNames.add("ElectronicText")
+
+ passedEntityNames.add("ProductType")
+ passedEntityNames.add("Product")
+ passedEntityNames.add("ProductAttribute")
+ passedEntityNames.add("GoodIdentificationType")
+ passedEntityNames.add("GoodIdentification")
+ passedEntityNames.add("ProductPriceType")
+ passedEntityNames.add("ProductPrice")
+
+ passedEntityNames.add("ProductPriceRule")
+ passedEntityNames.add("ProductPriceCond")
+ passedEntityNames.add("ProductPriceAction")
+ //passedEntityNames.add("ProductPriceChange")
+
+ passedEntityNames.add("ProductPromo")
+ passedEntityNames.add("ProductPromoCode")
+ passedEntityNames.add("ProductPromoCategory")
+ passedEntityNames.add("ProductPromoProduct")
+ passedEntityNames.add("ProductPromoRule")
+ passedEntityNames.add("ProductPromoAction")
+ passedEntityNames.add("ProductPromoCodeEmail")
+ passedEntityNames.add("ProductPromoCodeParty")
+ passedEntityNames.add("ProductPromoCond")
+
+ passedEntityNames.add("ProductCategoryMember")
+ passedEntityNames.add("ProductAssoc")
+ passedEntityNames.add("ProductContent")
+
+ passedEntityNames.add("ProductFeature")
+ passedEntityNames.add("ProductFeatureCategoryAppl")
+ passedEntityNames.add("ProductFeatureAppl")
+ passedEntityNames.add("ProductFeatureDataResource")
+ passedEntityNames.add("ProductFeatureGroup")
+ passedEntityNames.add("ProductFeatureCatGrpAppl")
+ passedEntityNames.add("ProductFeatureGroupAppl")
+
+ //passedEntityNames.add("ProductKeyword")
+}
+
+if (entitySyncId) {
+ passedEntityNames =
org.apache.ofbiz.entityext.synchronization.EntitySyncContext.getEntitySyncModelNamesToUse(dispatcher,
entitySyncId)
+}
+checkAll = "true".equals(parameters.checkAll)
+tobrowser = parameters.tobrowser != null
+context.tobrowser = tobrowser
+
+entityFromCond = null
+entityThruCond = null
+entityDateCond = null
+if (entityFrom) {
+ entityFromCond = EntityCondition.makeCondition("lastUpdatedTxStamp",
EntityComparisonOperator.GREATER_THAN, entityFrom)
+}
+if (entityThru) {
+ entityThruCond = EntityCondition.makeCondition("lastUpdatedTxStamp",
EntityComparisonOperator.LESS_THAN, entityThru)
+}
+if (entityFromCond && entityThruCond) {
+ entityDateCond = EntityCondition.makeCondition(entityFromCond,
EntityJoinOperator.AND, entityThruCond)
+} else if (entityFromCond) {
+ entityDateCond = entityFromCond
+} else if (entityThruCond) {
+ entityDateCond = entityThruCond
+}
+
+reader = delegator.getModelReader()
+modelEntities = reader.getEntityCache().values() as TreeSet
+context.modelEntities = modelEntities
+
+if (passedEntityNames) {
+ if (tobrowser) {
+ session.setAttribute("jsonrawdump_entitylist", passedEntityNames)
+ session.setAttribute("entityDateCond", entityDateCond)
+ } else {
+ efo = new EntityFindOptions(true,
EntityFindOptions.TYPE_SCROLL_INSENSITIVE, EntityFindOptions.CONCUR_READ_ONLY,
true)
+ numberOfEntities = passedEntityNames?.size() ?: 0
+ context.numberOfEntities = numberOfEntities
+ numberWritten = 0
+ currentIndexEntity = 0
+
+ // single file
+ if (filename && numberOfEntities) {
+ if (outpath && !(filename.contains("/") &&
filename.contains("\\"))) {
+ filename = outpath + File.separator + filename;
+ }
+ writer = new PrintWriter(new BufferedWriter(new
OutputStreamWriter(new FileOutputStream(filename), "UTF-8")))
+ writer.println('[')
+
+ passedEntityNames.each { curEntityName ->
+ if (entityFrom) {
+ curModelEntity = reader.getModelEntity(curEntityName)
+ if (curModelEntity instanceof ModelViewEntity) {
+ return
+ }
+ }
+ currentIndexEntity++;
+ beganTransaction = TransactionUtil.begin(3600)
+ try {
+ me = reader.getModelEntity(curEntityName)
+ if (me.getNoAutoStamp() || me instanceof ModelViewEntity) {
+ values = delegator.find(curEntityName, null, null,
null, me.getPkFieldNames(), efo)
+ } else {
+ values = delegator.find(curEntityName, entityDateCond,
null, null, UtilMisc.toList("-createdTxStamp"), efo)
+ }
+
+ curNumberWritten = 0
+ writer.print('{');
+ writer.print('"');
+ writer.print(curEntityName);
+ writer.print('"');
+ writer.print(':');
+ writer.print('[');
+ while (value = values.next()) {
+
org.apache.ofbiz.webtools.EntityJsonHelper.writeJsonText(writer, value)
+ numberWritten++
+ curNumberWritten++
+ if (curNumberWritten % 500 == 0 || curNumberWritten ==
1) {
+ Debug.log("Records written [$curEntityName]:
$curNumberWritten Total: $numberWritten")
+ }
+ if(curNumberWritten <
values.getResultsSizeAfterPartialList()) {
+ writer.print(",");
+ }
+ }
+ writer.print("]}");
+ values.close()
+ Debug.log("Wrote [$curNumberWritten] from entity :
$curEntityName")
+ TransactionUtil.commit(beganTransaction)
+ } catch (Exception e) {
+ errMsg = "Error reading data for JSON export:"
+ Debug.logError(e, errMsg, "JSP")
+ TransactionUtil.rollback(beganTransaction, errMsg, e)
+ }
+ if(currentIndexEntity < numberOfEntities) {
+ writer.println(',');
+ } else {
+ writer.println('');
+ }
+ }
+ writer.print(']')
+ writer.close()
+ Debug.log("Total records written from all entities:
$numberWritten")
+ context.numberWritten = numberWritten
+ }
+
+ // multiple files in a directory
+ results = []
+ fileNumber = 1
+ context.results = results
+ if (outpath && !filename) {
+ outdir = new File(outpath)
+ if (!outdir.exists()) {
+ outdir.mkdir()
+ }
+ if (outdir.isDirectory() && outdir.canWrite()) {
+ passedEntityNames.each { curEntityName ->
+ numberWritten = 0
+ fileName = preConfiguredSetName ?
UtilFormatOut.formatPaddedNumber((long) fileNumber, 3) + "_" : ""
+ fileName = fileName + curEntityName
+
+ values = null
+ beganTransaction = false
+ try {
+ beganTransaction = TransactionUtil.begin(3600)
+
+ me = delegator.getModelEntity(curEntityName)
+ if (me instanceof ModelViewEntity) {
+ results.add("[$fileNumber] [vvv] $curEntityName
skipping view entity")
+ return
+ }
+ if (me.getNoAutoStamp() || me instanceof
ModelViewEntity) {
+ values = delegator.find(curEntityName, null, null,
null, me.getPkFieldNames(), efo)
+ } else {
+ values = delegator.find(curEntityName,
entityDateCond, null, null, me.getPkFieldNames(), efo)
+ }
+ isFirst = true
+ writer = null
+ fileSplitNumber = 1
+ curValueCount = 0
+ while (value = values.next()) {
+ //Don't bother writing the file if there's nothing
+ //to put into it
+ if (isFirst) {
+ writer = new PrintWriter(new
BufferedWriter(new OutputStreamWriter(new FileOutputStream(new File(outdir,
fileName +".json")), "UTF-8")))
+ writer.println('[');
+ writer.print('{');
+ writer.print('"');
+ writer.print(curEntityName);
+ writer.print('"');
+ writer.print(':');
+ writer.print('[')
+ isFirst = false
+ }
+
org.apache.ofbiz.webtools.EntityJsonHelper.writeJsonText(writer, value)
+ numberWritten++
+ curValueCount++
+ if(curValueCount <
values.getResultsSizeAfterPartialList()) {
+ writer.println(',')
+ }
+
+ // split into small files
+ if (maxRecordsPerFile > 0 && (numberWritten %
maxRecordsPerFile == 0)) {
+ fileSplitNumber++
+ // close the file
+ writer.println("]}")
+ writer.print("]")
+ writer.close()
+
+ // create a new file
+ splitNumStr =
UtilFormatOut.formatPaddedNumber((long) fileSplitNumber, 3)
+ writer = new PrintWriter(new
BufferedWriter(new OutputStreamWriter(new FileOutputStream(new File(outdir,
fileName + "_" + splitNumStr +".json")), "UTF-8")))
+ writer.println('[');
+ writer.print('{');
+ writer.print('"');
+ writer.print(curEntityName);
+ writer.print('"');
+ writer.print(':');
+ writer.print('[');
+ }
+
+ if (numberWritten % 500 == 0 || numberWritten ==
1) {
+ Debug.log("Records written [$curEntityName]:
$numberWritten")
+ }
+
+ }
+ if (writer) {
+ writer.println("]}")
+ writer.print("]")
+ writer.close()
+ String thisResult = "[$fileNumber]
[$numberWritten] $curEntityName wrote $numberWritten records"
+ Debug.log(thisResult)
+ results.add(thisResult)
+ } else {
+ thisResult = "[$fileNumber] [---] $curEntityName
has no records, not writing file"
+ Debug.log(thisResult)
+ results.add(thisResult)
+ }
+ values.close()
+ } catch (Exception ex) {
+ if (values != null) {
+ values.close()
+ }
+ thisResult = "[$fileNumber] [xxx] Error when writing
$curEntityName: $ex"
+ Debug.log(thisResult)
+ results.add(thisResult)
+ TransactionUtil.rollback(beganTransaction, thisResult,
ex)
+ } finally {
+ // only commit the transaction if we started one...
this will throw an exception if it fails
+ TransactionUtil.commit(beganTransaction)
+ }
+ fileNumber++
+ }
+ }
+ }
+ }
+} else {
+ context.numberOfEntities = 0
+}
Propchange:
ofbiz/ofbiz-framework/trunk/framework/webtools/groovyScripts/entity/JsonDsDump.groovy
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
ofbiz/ofbiz-framework/trunk/framework/webtools/groovyScripts/entity/JsonDsDump.groovy
------------------------------------------------------------------------------
svn:keywords = Date Rev Author URL Id
Propchange:
ofbiz/ofbiz-framework/trunk/framework/webtools/groovyScripts/entity/JsonDsDump.groovy
------------------------------------------------------------------------------
svn:mime-type = text/plain
Modified: ofbiz/ofbiz-framework/trunk/framework/webtools/servicedef/services.xml
URL:
http://svn.apache.org/viewvc/ofbiz/ofbiz-framework/trunk/framework/webtools/servicedef/services.xml?rev=1862206&r1=1862205&r2=1862206&view=diff
==============================================================================
--- ofbiz/ofbiz-framework/trunk/framework/webtools/servicedef/services.xml
(original)
+++ ofbiz/ofbiz-framework/trunk/framework/webtools/servicedef/services.xml Thu
Jun 27 11:49:22 2019
@@ -56,6 +56,36 @@ under the License.
<attribute name="placeholderValues" type="java.util.Map" mode="IN"
optional="true"/>
<attribute name="messages" type="List" mode="OUT" optional="false"/>
</service>
+ <service name="parseEntityJsonFile" engine="java"
+ location="org.apache.ofbiz.webtools.WebToolsServices"
invoke="parseEntityJsonFile" auth="true" use-transaction="false">
+ <description>Parses an entity xml file or an entity xml
text</description>
+ <permission-service service-name="entityMaintPermCheck"
main-action="VIEW"/>
+ <attribute name="url" type="java.net.URL" mode="IN" optional="true"/>
+ <attribute name="xmltext" type="String" mode="IN" optional="true"
allow-html="any"/>
+ <attribute name="onlyInserts" type="String" mode="IN" optional="true"/>
+ <attribute name="maintainTimeStamps" type="String" mode="IN"
optional="true"/>
+ <attribute name="txTimeout" type="Integer" mode="IN" optional="true"/>
+ <attribute name="createDummyFks" type="String" mode="IN"
optional="true"/>
+ <attribute name="checkDataOnly" type="String" mode="IN"
optional="true"/>
+ <attribute name="placeholderValues" type="java.util.Map" mode="IN"
optional="true"/>
+ <attribute name="rowProcessed" type="Long" mode="OUT"
optional="false"/>
+ </service>
+ <service name="entityImportJson" engine="java"
+ location="org.apache.ofbiz.webtools.WebToolsServices"
invoke="entityImportJson" auth="true" use-transaction="false">
+ <description>Imports an entity xml file or text string</description>
+ <permission-service service-name="entityMaintPermCheck"
main-action="VIEW"/>
+ <attribute name="filename" type="String" mode="IN" optional="true"
allow-html="any"/>
+ <attribute name="fmfilename" type="String" mode="IN" optional="true"
allow-html="any"/>
+ <attribute name="fulltext" type="String" mode="IN" optional="true"
allow-html="any"/>
+ <attribute name="isUrl" type="String" mode="IN" optional="true"/>
+ <attribute name="onlyInserts" type="String" mode="IN" optional="true"/>
+ <attribute name="maintainTimeStamps" type="String" mode="IN"
optional="true"/>
+ <attribute name="createDummyFks" type="String" mode="IN"
optional="true"/>
+ <attribute name="checkDataOnly" type="String" mode="IN"
optional="true"/>
+ <attribute name="txTimeout" type="Integer" mode="IN" optional="true"/>
+ <attribute name="placeholderValues" type="java.util.Map" mode="IN"
optional="true"/>
+ <attribute name="messages" type="List" mode="OUT" optional="false"/>
+ </service>
<service name="entityImportDir" engine="java"
location="org.apache.ofbiz.webtools.WebToolsServices"
invoke="entityImportDir" auth="true" use-transaction="false">
<description>Imports all entity xml files contained in a
directory</description>
@@ -71,6 +101,21 @@ under the License.
<attribute name="placeholderValues" type="java.util.Map" mode="IN"
optional="true"/>
<attribute name="messages" type="List" mode="OUT" optional="false"/>
</service>
+ <service name="entityImportDirJson" engine="java"
+ location="org.apache.ofbiz.webtools.WebToolsServices"
invoke="entityImportDirJson" auth="true" use-transaction="false">
+ <description>Imports all entity json files contained in a
directory</description>
+ <permission-service service-name="entityMaintPermCheck"
main-action="VIEW"/>
+ <attribute name="path" type="String" mode="IN" optional="true"/>
+ <attribute name="onlyInserts" type="String" mode="IN" optional="true"/>
+ <attribute name="maintainTimeStamps" type="String" mode="IN"
optional="true"/>
+ <attribute name="createDummyFks" type="String" mode="IN"
optional="true"/>
+ <attribute name="checkDataOnly" type="String" mode="IN"
optional="true"/>
+ <attribute name="deleteFiles" type="String" mode="IN" optional="true"/>
+ <attribute name="txTimeout" type="Integer" mode="IN" optional="true"/>
+ <attribute name="filePause" type="Long" mode="IN" optional="true"/>
+ <attribute name="placeholderValues" type="java.util.Map" mode="IN"
optional="true"/>
+ <attribute name="messages" type="List" mode="OUT" optional="false"/>
+ </service>
<service name="entityImportReaders" engine="java"
location="org.apache.ofbiz.webtools.WebToolsServices"
invoke="entityImportReaders" auth="true" use-transaction="false">
<description>Imports an entity xml file or text string</description>
@@ -91,6 +136,15 @@ under the License.
<permission-service service-name="entityMaintPermCheck"
main-action="VIEW"/>
<attribute name="outpath" type="String" mode="IN" optional="true"/>
<attribute name="fromDate" type="Timestamp" mode="IN" optional="true"/>
+ <attribute name="txTimeout" type="Integer" mode="IN" optional="true"/>
+ <attribute name="results" type="List" mode="OUT" optional="false"/>
+ </service>
+ <service name="entityExportAllJson" engine="java"
+ location="org.apache.ofbiz.webtools.WebToolsServices"
invoke="entityExportAllJson" auth="true" use-transaction="false">
+ <description>Exports all entities into json files</description>
+ <permission-service service-name="entityMaintPermCheck"
main-action="VIEW"/>
+ <attribute name="outpath" type="String" mode="IN" optional="true"/>
+ <attribute name="fromDate" type="Timestamp" mode="IN" optional="true"/>
<attribute name="txTimeout" type="Integer" mode="IN" optional="true"/>
<attribute name="results" type="List" mode="OUT" optional="false"/>
</service>
