2.3.3. 部署调用示例合约
2.3.3.1. 使用cmc工具部署调用合约
代码语言：javascript复制## 创建合约
./cmc client contract user create
--contract-name=fact
--runtime-type=DOCKER_GO
--byte-code-path=./testdata/claim-docker-go-demo/docker-fact.7z
--version=1.0
--sdk-conf-path=./testdata/sdk_config.yml
--admin-key-file-paths=./testdata/crypto-config/wx-org1.chainmaker.org/user/admin1/admin1.tls.key,./testdata/crypto-config/wx-org2.chainmaker.org/user/admin1/admin1.tls.key,./testdata/crypto-config/wx-org3.chainmaker.org/user/admin1/admin1.tls.key,./testdata/crypto-config/wx-org4.chainmaker.org/user/admin1/admin1.tls.key
--admin-crt-file-paths=./testdata/crypto-config/wx-org1.chainmaker.org/user/admin1/admin1.tls.crt,./testdata/crypto-config/wx-org2.chainmaker.org/user/admin1/admin1.tls.crt,./testdata/crypto-config/wx-org3.chainmaker.org/user/admin1/admin1.tls.crt,./testdata/crypto-config/wx-org4.chainmaker.org/user/admin1/admin1.tls.crt
--sync-result=true
--params="{}"
## 调用合约
./cmc client contract user invoke
--contract-name=fact
--method=save
--sdk-conf-path=./testdata/sdk_config.yml
--params="{"file_name":"name007","file_hash":"ab3456df5799b87c77e7f88","time":"6543234"}"
--sync-result=true
## 查询合约
./cmc client contract user get
--contract-name=fact
--method=findByFileHash
--sdk-conf-path=./testdata/sdk_config.yml
--params="{"file_hash":"ab3456df5799b87c77e7f88"}"2.3.3.2. 使用Go SDK部署调用合约
代码语言：javascript复制// 创建合约
func testUserContractCreate(client *sdk.ChainClient, withSyncResult bool, isIgnoreSameContract bool, usernames ...string) {
resp, err := createUserContract(client, factContractName, factVersion, factByteCodePath,
common.RuntimeType_DOCKER_GO, []*common.KeyValuePair{}, withSyncResult, usernames...)
if !isIgnoreSameContract {
if err != nil {
log.Fatalln(err)
}
}
fmt.Printf("CREATE claim contract resp: % vn", resp)
}
func createUserContract(client *sdk.ChainClient, contractName, version, byteCodePath string, runtime common.RuntimeType, kvs []*common.KeyValuePair, withSyncResult bool, usernames ...string) (*common.TxResponse, error) {
payload, err := client.CreateContractCreatePayload(contractName, version, byteCodePath, runtime, kvs)
if err != nil {
return nil, err
}
endorsers, err := examples.GetEndorsers(payload, usernames...)
if err != nil {
return nil, err
}
resp, err := client.SendContractManageRequest(payload, endorsers, createContractTimeout, withSyncResult)
if err != nil {
return nil, err
}
err = examples.CheckProposalRequestResp(resp, true)
if err != nil {
return nil, err
}
return resp, nil
}
// 调用合约
// 调用或者查询合约时，method参数请设置为 invoke_contract，此方法会调用合约的InvokeContract方法，再通过参数获得具体方法
func testUserContractInvoke(client *sdk.ChainClient, method string, withSyncResult bool) (string, error) {
curTime := strconv.FormatInt(time.Now().Unix(), 10)
fileHash := uuid.GetUUID()
kvs := []*common.KeyValuePair{
{
Key: "method",
Value: []byte("save"),
},
{
Key: "time",
Value: []byte(curTime),
},
{
Key: "file_hash",
Value: []byte(fileHash),
},
{
Key: "file_name",
Value: []byte(fmt.Sprintf("file_%s", curTime)),
},
}
err := invokeUserContract(client, factContractName, method, "", kvs, withSyncResult)
if err != nil {
return "", err
}
return fileHash, nil
}
func invokeUserContract(client *sdk.ChainClient, contractName, method, txId string, kvs []*common.KeyValuePair, withSyncResult bool) error {
resp, err := client.InvokeContract(contractName, method, txId, kvs, -1, withSyncResult)
if err != nil {
return err
}
if resp.Code != common.TxStatusCode_SUCCESS {
return fmt.Errorf("invoke contract failed, [code:%d]/[msg:%s]n", resp.Code, resp.Message)
}
if !withSyncResult {
fmt.Printf("invoke contract success, resp: [code:%d]/[msg:%s]/[txId:%s]n", resp.Code, resp.Message, resp.ContractResult.Result)
} else {
fmt.Printf("invoke contract success, resp: [code:%d]/[msg:%s]/[contractResult:%s]n", resp.Code, resp.Message, resp.ContractResult)
}
return nil
}2.4. 接口描述
用户与链交互接口
代码语言：javascript复制type SDKInterface interface {
// GetArgs get arg from transaction parameters
// @return: 参数map
GetArgs() map[string][]byte
// GetState get [key, field] from chain and db
// @param key: 获取的参数名
// @param field: 获取的参数名
// @return1: 获取结果，格式为string
// @return2: 获取错误信息
GetState(key, field string) (string, error)
// GetBatchState get [BatchKeys] from chain and db
// @param batchKey: 获取的参数名
// @return1: 获取结果
// @return2: 获取错误信息
GetBatchState(batchKeys []*vmPb.BatchKey) ([]*vmPb.BatchKey, error)
// GetStateByte get [key, field] from chain and db
// @param key: 获取的参数名
// @param field: 获取的参数名
// @return1: 获取结果，格式为[]byte
// @return2: 获取错误信息
GetStateByte(key, field string) ([]byte, error)
// GetStateFromKey get [key] from chain and db
// @param key: 获取的参数名
// @return1: 获取结果，格式为string
// @return2: 获取错误信息
GetStateFromKey(key string) (string, error)
// GetStateFromKeyByte get [key] from chain and db
// @param key: 获取的参数名
// @return1: 获取结果，格式为[]byte
// @return2: 获取错误信息
GetStateFromKeyByte(key string) ([]byte, error)
// PutState put [key, field, value] to chain
// @param1 key: 参数名
// @param1 field: 参数名
// @param2 value: 参数值，类型为string
// @return1: 上传参数错误信息
PutState(key, field string, value string) error
// PutStateByte put [key, field, value] to chain
// @param1 key: 参数名
// @param1 field: 参数名
// @param2 value: 参数值，类型为[]byte
// @return1: 上传参数错误信息
PutStateByte(key, field string, value []byte) error
// PutStateFromKey put [key, value] to chain
// @param1 key: 参数名
// @param2 value: 参数值，类型为string
// @return1: 上传参数错误信息
PutStateFromKey(key string, value string) error
// PutStateFromKeyByte put [key, value] to chain
// @param1 key: 参数名
// @param2 value: 参数值，类型为[]byte
// @return1: 上传参数错误信息
PutStateFromKeyByte(key string, value []byte) error
// DelState delete [key, field] to chain
// @param1 key: 删除的参数名
// @param1 field: 删除的参数名
// @return1：删除参数的错误信息
DelState(key, field string) error
// DelStateFromKey delete [key] to chain
// @param1 key: 删除的参数名
// @return1：删除参数的错误信息
DelStateFromKey(key string) error
// GetCreatorOrgId get tx creator org id
// @return1: 合约创建者的组织ID
// @return2: 获取错误信息
GetCreatorOrgId() (string, error)
// GetCreatorRole get tx creator role
// @return1: 合约创建者的角色
// @return2: 获取错误信息
GetCreatorRole() (string, error)
// GetCreatorPk get tx creator pk
// @return1: 合约创建者的公钥
// @return2: 获取错误信息
GetCreatorPk() (string, error)
// GetSenderOrgId get tx sender org id
// @return1: 交易发起者的组织ID
// @return2: 获取错误信息
GetSenderOrgId() (string, error)
// GetSenderRole get tx sender role
// @return1: 交易发起者的角色
// @return2: 获取错误信息
GetSenderRole() (string, error)
// GetSenderPk get tx sender pk
// @return1: 交易发起者的公钥
// @return2: 获取错误信息
GetSenderPk() (string, error)
// GetBlockHeight get tx block height
// @return1: 当前块高度
// @return2: 获取错误信息
GetBlockHeight() (int, error)
// GetTxId get current tx id
// @return1: 交易ID
// @return2: 获取错误信息
GetTxId() (string, error)
// GetTxInfo get tx info
// @param txId :合约交易ID
GetTxInfo(txId string) protogo.Response
// GetTxTimeStamp get tx timestamp
// @return1: 交易timestamp
// @return2: 获取错误信息
GetTxTimeStamp() (string, error)
// EmitEvent emit event, you can subscribe to the event using the SDK
// @param1 topic: 合约事件的主题
// @param2 data: 合约事件的数据，参数数量不可大于16
EmitEvent(topic string, data []string)
// Log record log to chain server
// @param message: 事情日志的信息
//Deprecated
Log(message string)
// Debugf record log to chain server
// @param format: 日志格式化模板
// @param a: 模板参数
Debugf(format string, a ...interface{})
// Infof record log to chain server
// @param format: 日志格式化模板
// @param a: 模板参数
Infof(format string, a ...interface{})
// Warnf record log to chain server
// @param format: 日志格式化模板
// @param a: 模板参数
Warnf(format string, a ...interface{})
// Errorf record log to chain server
// @param format: 日志格式化模板
// @param a: 模板参数
Errorf(format string, a ...interface{})
// CallContract invoke another contract and get response
// @param1: 合约名称
// @param2: 合约方法
// @param3: 合约合约参数
// @return1: 合约结果
CallContract(contractName, method string, args map[string][]byte) protogo.Response
// NewIterator range of [startKey, limitKey), front closed back open
// @param1: 范围查询起始key
// @param2: 范围查询结束key
// @return1: 根据起始key生成的迭代器
// @return2: 获取错误信息
NewIterator(startKey string, limitKey string) (ResultSetKV, error)
// NewIteratorWithField range of [key "#" startField, key "#" limitField), front closed back open
// @param1: 分别与param2, param3 构成查询起始和结束的key
// @param2: [param1 "#" param2] 来获取查询起始的key
// @param3: [param1 "#" param3] 来获取查询结束的key
// @return1: 根据起始位置生成的迭代器
// @return2: 获取错误信息
NewIteratorWithField(key string, startField string, limitField string) (ResultSetKV, error)
// NewIteratorPrefixWithKeyField range of [key "#" field, key "#" field], front closed back closed
// @param1: [ param1 "#" param2 ] 构成前缀范围查询的key
// @param2: [ param1 "#" param2 ] 构成前缀范围查询的key
// @return1: 根据起始位置生成的迭代器
// @return2: 获取错误信息
NewIteratorPrefixWithKeyField(key string, field string) (ResultSetKV, error)
// NewIteratorPrefixWithKey range of [key, key], front closed back closed
// @param1: 前缀范围查询起始key
// @return1: 根据起始位置生成的迭代器
// @return2: 获取错误信息
NewIteratorPrefixWithKey(key string) (ResultSetKV, error)
// NewHistoryKvIterForKey query all historical data of key, field
// @param1: 查询历史的key
// @param2: 查询历史的field
// @return1: 根据key, field 生成的历史迭代器
// @return2: 获取错误信息
NewHistoryKvIterForKey(key, field string) (KeyHistoryKvIter, error)
// GetSenderAddr Get the address of the tx sender
// @return1: 交易发起方地址
// @return2: 获取错误信息
//Deprecated
GetSenderAddr() (string, error)
// Sender Get the address of the tx sender address
// @return1: 交易发起方地址
// @return2: 获取错误信息
Sender() (string, error)
// Origin Get the address of the tx origin address
// @return1: 交易
// @return2: 获取错误信息
Origin() (string, error)
}
