implements deleteSchema

shaxunyeman · shaxunyeman · commit aab8a02c0306 · 2022-04-08T10:14:38.000+08:00
diff --git a/src/index.js b/src/index.js
@@ -726,6 +726,7 @@ ChainsqlAPI.prototype.beginTran = function () {
 		this.transaction = true;
 		return;
 	}
+	throw chainsqlError("connect is undefine or connect.address is undefine")
 }
 
 function handleCommit(ChainSQL, object, resolve, reject) {
@@ -1366,6 +1367,27 @@ ChainsqlAPI.prototype.modifySchema = function(schemaInfo){
 	return this;
 };
 
+ChainsqlAPI.prototype.deleteSchema = function(schemaInfo){
+
+	let bValid = (schemaInfo !== undefined) 
+				&& (schemaInfo.SchemaID !== undefined) 
+
+	if(!bValid){
+		throw new Error("Invalid deleteSchema parameter");
+	}       
+
+	var schemaDeleteTxJson = {
+		Account: this.connect.address,
+		SchemaID: schemaInfo.SchemaID,
+		TransactionType: 'SchemaDelete'
+	};
+
+	// 修改子链
+	this.schemaModifyTx = true;
+	this.payment = schemaDeleteTxJson;
+	return this;
+};
+
 function callback(data, callback) {
 
 }
