This is an automated email from the ASF dual-hosted git repository. lta pushed a commit to branch serialize-physicalplan in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 614f85efe1b04c46c0a525a27d9a1ab3558124fa Author: lta <[email protected]> AuthorDate: Wed Mar 27 23:08:02 2019 +0800 add physical codec unit test --- .../transfer/PhysicalPlanLogTransferTest.java | 47 ++++++++++++++++++++++ 1 file changed, 47 insertions(+) diff --git a/iotdb/src/test/java/org/apache/iotdb/db/writelog/transfer/PhysicalPlanLogTransferTest.java b/iotdb/src/test/java/org/apache/iotdb/db/writelog/transfer/PhysicalPlanLogTransferTest.java index 51a410b..5bea2d3 100644 --- a/iotdb/src/test/java/org/apache/iotdb/db/writelog/transfer/PhysicalPlanLogTransferTest.java +++ b/iotdb/src/test/java/org/apache/iotdb/db/writelog/transfer/PhysicalPlanLogTransferTest.java @@ -105,6 +105,53 @@ public class PhysicalPlanLogTransferTest { public void logToOperator() throws IOException, ArgsErrorException, ProcessorException, QueryProcessorException, AuthException { + /** Insert Plan test **/ + byte[] insertPlanBytesTest = PhysicalPlanLogTransfer.operatorToLog(insertPlan); + InsertPlan insertPlanTest = (InsertPlan) PhysicalPlanLogTransfer + .logToOperator(insertPlanBytesTest); + assertEquals(true, insertPlanTest.equals(insertPlan)); + + /** Delete Plan test **/ + byte[] deletePlanBytesTest = PhysicalPlanLogTransfer.operatorToLog(deletePlan); + DeletePlan deletePlanTest = (DeletePlan) PhysicalPlanLogTransfer + .logToOperator(deletePlanBytesTest); + assertEquals(true, deletePlanTest.equals(deletePlan)); + + /** Update Plan test **/ + byte[] updatePlanBytesTest = PhysicalPlanLogTransfer.operatorToLog(updatePlan); + UpdatePlan updatePlanTest = (UpdatePlan) PhysicalPlanLogTransfer + .logToOperator(updatePlanBytesTest); + assertEquals(true, updatePlanTest.equals(updatePlan)); + + /** Metadata Plan test **/ + String metadataStatement = "create timeseries root.vehicle.d1.s1 with datatype=INT32,encoding=RLE"; + MetadataPlan metadataPlan = (MetadataPlan) processor.parseSQLToPhysicalPlan(metadataStatement); + byte[] metadataPlanBytesTest = PhysicalPlanLogTransfer.operatorToLog(metadataPlan); + MetadataPlan metadataPlanTest = (MetadataPlan) PhysicalPlanLogTransfer + .logToOperator(metadataPlanBytesTest); + assertEquals(true, metadataPlanTest.equals(metadataPlan)); + + /** Author Plan test **/ + String sql = "grant role xm privileges 'SET_STORAGE_GROUP','DELETE_TIMESERIES' on root.vehicle.device.sensor"; + AuthorPlan authorPlan = (AuthorPlan) processor.parseSQLToPhysicalPlan(sql); + byte[] authorPlanBytesTest = PhysicalPlanLogTransfer.operatorToLog(authorPlan); + AuthorPlan authorPlanTest = (AuthorPlan) PhysicalPlanLogTransfer + .logToOperator(authorPlanBytesTest); + assertEquals(true, authorPlanTest.equals(authorPlan)); + + /** LoadData Plan test **/ + byte[] loadDataPlanBytesTest = PhysicalPlanLogTransfer.operatorToLog(loadDataPlan); + LoadDataPlan loadDataPlanTest = (LoadDataPlan) PhysicalPlanLogTransfer + .logToOperator(loadDataPlanBytesTest); + assertEquals(true, loadDataPlan.equals(loadDataPlanTest)); + + /** Property Plan test **/ + sql = "add label label1021 to property propropro"; + PropertyPlan propertyPlan = (PropertyPlan) processor.parseSQLToPhysicalPlan(sql); + byte[] propertyPlanBytesTest = PhysicalPlanLogTransfer.operatorToLog(propertyPlan); + PropertyPlan propertyPlanTest = (PropertyPlan) PhysicalPlanLogTransfer + .logToOperator(propertyPlanBytesTest); + assertEquals(true, propertyPlanTest.equals(propertyPlan)); } } \ No newline at end of file
