Chainsql使用相關筆記
安裝
按照 github 上 chainsql 的 SQL/chainsqld/blob/master/doc/manual/deploy.md#1-%E5%AE%89%E8%A3%85mysql" target="_blank" rel="nofollow,noindex">安裝過程 ， 這裡主要介紹區塊網路搭建過程（ 4 個驗證節點，其中只有一個節點[10.11.6.120]配置了資料庫）：
1、根據官方文件上 配置檔案 的案例，修改 chainsql.cfg 。 這裡要注意 peer,rpc,wss_admin,wss_public 的埠配置，如下案例中 4 個節點的配置，其中一個節點的配置資訊如下：
#埠配置列表 [server] port_rpc_admin_local port_peer port_ws_admin_local #http埠配置 [port_rpc_admin_local] port = 5005 ip = 127.0.0.1 admin = 127.0.0.1 protocol = http #peer埠配置，用於p2p節點發現 [port_peer] port = 51235 ip = 0.0.0.0 protocol = peer #websocket埠配置 [port_ws_admin_local] port = 6006 ip = 127.0.0.1 admin = 127.0.0.1 protocol = ws
其餘的配置資訊部分如下：
#對等連線的其他主機的ip，以及對於的peer埠設定 [ips_fixed] 10.11.6.116 51236 10.11.6.117 51237 10.11.6.118 51238
還有要注意的是，就是sync_db注意在centos下要修改unix_socket的配置。以及auto_sync開啟設為1。
2、執行./chainsqld --conf="./ chainsqld-example.cfg" validation_create生成相應的validators、validation_seed（金鑰）、validation_public_key（公鑰），內容如下。將這些生成的內容加入chainsql.cfg中。其他四個節點也依此配置。
{
"id" : 1,
"result" : {
"status" : "success",
"validation_key" : "OTT SOME DEE WOVE EAT SOME QUOD KUDO NIP HOW LEER HOSE",
"validation_private_key" : "pcvYu2QigM37t2jGar6EJSsRSdsV7H63R2Ae52WTZycZqNseT8a",
"validation_public_key" : "n9KnRfJ3wnCF8WaGmhf3EENSfMxc3KyWLzEKXmnP5pssZkci53DV",
"validation_seed" : "xxSm9kEKBDqrrfskWJV8wXRc6izLQ"
}
}
根據文件中結構網路完成後，四個節點都啟動後可以檢視其他節點的執行情況，成功配置後節點的執行情況如下圖所示：watch ./chainsqld peers。
對chainsql 資料庫的操作
按照chainsql的 使用說明 進行操作，去github上下載 node-chain-sql ，在package.json的dependencies中新增“chainsql":"^0.6.20”。執行 然後執行npm install命令和npm install chainsql --save，如果第二個語句執行不成功，則將執行語句換成npm install chainsql --save --force。要注意的是使用說明中一些測死案例是在node7.6的版本的基礎上去使用的， 如果版本錯誤，會出現一些符號錯誤的問題(如await等非同步同步問題)。
1、建立使用者
根據 文件說明 ，首先要建立根使用者，通過根賬戶（文件中說明了根賬戶如何建立）向新建的賬戶轉賬，才能啟用新賬戶，建立賬戶的程式碼如下，其中owner是生成的根賬戶資訊：
'use strict'; const ChainsqlAPI = require('chainsql').ChainsqlAPI; const c = new ChainsqlAPI(); var owner = { secret: "xnoPBzXtMeMyMHUVTgbuqAfg1SUTb", address: "zHb9CJAWyB4zj91VRWn96DkukG4bwdtyTh" } //var user ={ //secret: 'xx26wgq6XbnTLrNgDn21dqjBMsD38', //address: 'zp7mxMmrDwAGQqPeSBpT5wKaM4RpGaKWeW' //} let account = c.generateAddress(); console.log(account) c.connect('ws://127.0.0.1:6006').then( ()=>{ console.log('連線成功') c.as(owner);//這裡owner指一個有足夠zxc的賬戶，第一個轉賬操作肯定要用根賬戶 let ret = c.pay(account.address,100000000).then((ret)=>{ console.log(ret); }) } );
輸出結果為tesSUCCESS 說明提交成功。
2、建立資料庫，以及往資料庫中插入資料
根據官方的 使用說明 ，可以根據以下的案例，其中的user是剛才啟用的新賬戶。
'use strict';
const ChainsqlAPI = require('chainsql').ChainsqlAPI;
const r = new ChainsqlAPI();
var user = {
secret: 'xpiCV45NQ3bRxPJvmjBgkTLPwMqAC',
address: 'zNn8qGS3spd8vyRJ88NpymiGEqKxvxgikY',
publicKey: 'cBQFdZcmk5xsbqN8yPvk1Ay9L4PrgviGwcHxzoT7gN2XRtfqXzRR'
}
r.connect('ws://127.0.0.1:6006', function(err, data) {
if (err) {
console.log('連線失敗. ');
return
}
console.log('連線成功');
r.as(user);
r.createTable("dc_universe", [
{
'field':'id',
'type':'int',
'length':11,
'PK':1,
'NN':1,
'UQ':1
},
{
'field':'name',
'type':'varchar',
'length':50,
'default':null
},
{
'field':'age',
'type':'int'
}]
).submit();
r.table("dc_universe").insert({id:1, name: 'peera',age: 22},{id:2, name: 'peerb',age: 21}).submit();
getLedger();
});
function getLedger() {
r.getLedger({
ledgerVersion: 22
}, function(err, data) {
console.log(err, data)
})
}
一次性向資料庫的表中插入多條資料，同時檢視交易資訊，可以根據以下的案例進行測試，這個user是另外啟用的新賬戶，與上面不同：
'use strict';
const ChainsqlAPI = require('chainsql').ChainsqlAPI;
const c = new ChainsqlAPI();
var root = {
secret: 'xnoPBzXtMeMyMHUVTgbuqAfg1SUTb',
address: 'zHb9CJAWyB4zj91VRWn96DkukG4bwdtyTh'
}
var user ={
secret: 'xx26wgq6XbnTLrNgDn21dqjBMsD38',
address: 'zp7mxMmrDwAGQqPeSBpT5wKaM4RpGaKWeW'
}
c.connect('ws://127.0.0.1:6006').then( async ()=>{
console.log('連線成功')
c.as(root);//這裡owner指一個有足夠zxc的賬戶，第一個轉賬操作肯定要用根賬戶
c.setRestrict(false);
// var raw=[ { id: 61, name: 'peer61', age: 71 },{ id: 62, name: 'peer62', age: 72 }];
var raw=[];
for(var i=62;i<67;i++){
raw.push({'id':i, 'name': 'peer'+i,'age': i+10});
//var raw=[{id:15+i, name: 'gqx'+i,age: 23+i}];
//console.log(raw);
//c.table("dc_universe").insert(raw).submit({expect:'db_success'});
}
// console.log(raw);
// var raw=[
//{'id':7, 'name': 'gqx11','age': 25},
//{'id':8, 'name': 'gqx22','age': 45},
//{'id':9, 'name': 'gqx33','age': 64}
// ]
// var rs=await c.table("dc_universe").insert(raw).submit({expect:"db_success"});
// console.log(rs);
var opt = {limit:200}
c.getTransactions('zp7mxMmrDwAGQqPeSBpT5wKaM4RpGaKWeW',opt,callback);
}
);
function callback(err,data){
if(err){
console.error(err);
}else{
console.log(JSON.stringify(data));
}
}
最後，要注意一些問題，比如官方文件的說明中有些錯誤，比如插入資料的格式問題，還有架設網路的第二步中檢查是否成功，只需要在chainsql目錄中執行（centOs） watch ./chainsqld server_info等等。還有要注意插入資料時，插入資料的操作者要有足夠的費用去支援插入的行為，否則即使插入不成功，也不會出現錯誤資訊，很難發現錯誤。