peer chaincode install -n mycc -v 1.0 -p github.com/hyperledger/fabric/ chaincode/go/sequoiabc

CREATE FOREIGN TABLE product(id int, name text, price int, des text) SERVER sbc_fabric_svr OPTIONS(channelname ‘product’, chaincodename ‘product_cc’);

CREATE FOREIGN TABLE

CREATE FOREIGN TABLE bill(id int, product_id int, amount int) SERVER sbc_fabric_svr OPTIONS(channelname ‘bill’, chaincodename ‘bill_cc’);

CREATE FOREIGN TABLE

insert into product values (1, ‘apple’, 10, ‘苹果’);

INSERT 0 1

insert into product values (2, ‘banana’, 3, ‘香蕉’);

INSERT 0 1

insert into product values (3, ‘orange’, 2, ‘橘子’);

INSERT 0 1

insert into product values (4, ‘pear’, 7, ‘梨’);

INSERT 0 1

select * from product;

id | name | price | des

—- ——– ——- ——

1 | apple | 10 | 苹果

2 | banana | 3 | 香蕉

3 | orange | 2 | 橘子

4 | pear | 7 | 梨

(4 rows)

insert into bill values (1, 1, 20);

INSERT 0 1

insert into bill values (2, 1, 3);

INSERT 0 1

insert into bill values (3, 4, 15);

INSERT 0 1

select * from bill;

id | product_id | amount

—- ———— ——–

1 | 1 | 20

2 | 1 | 3

3 | 4 | 15

(3 rows)

select id, name, price from product where price > 5;

id | name | price

—- ——- ——-

1 | apple | 10

4 | pear | 7

(2 rows)

select product.id as product_id, bill.id as bill_id, product.name as name, product.price as price, bill.amount as amount from bill inner join product on bill.product_id = product.id;

product_id | bill_id | name | price | amount

———— ——— ——- ——- ——–

1 | 1 | apple | 10 | 20

1 | 2 | apple | 10 | 3

4 | 3 | pear | 7 | 15

(3 rows)

func (t *SimpleChaincode) insert(stub shim.ChaincodeStubInterface, args []string) pb.Response {

var name, info string

//var buffer bytes.Buffer

var err error

var marbleJSON map[string]interface{}

if len(args) != 2 {

return shim.Error(“Incorrect number of arguments. Expecting 2″)

}

name = args[0]

info = args[1]

valbytes, err := stub.GetState(name)

if err != nil {

return shim.Error(“Failed to get state”)

}

if valbytes != nil {

errInfo := fmt.Sprintf(“%s already exist”, name)

return shim.Error(errInfo)

}

if err := json.Unmarshal([]byte (info), &marbleJSON); err != nil {

return shim.Error(err.Error())

}

marbleJSON[“type”] = “fdw”

marbleJSONasBytes, err := json.Marshal(marbleJSON)

if err != nil {

return shim.Error(err.Error())

}

err = stub.PutState(name, marbleJSONasBytes)

if err != nil {

return shim.Error(err.Error())

}

return shim.Success(nil)

}

fabricExecForeignInsert(EState *estate,

ResultRelInfo *resultRelInfo,

TupleTableSlot *slot,

TupleTableSlot *planSlot)

{

Relation rel = resultRelInfo->ri_RelationDesc;

Oid foreignTableId = InvalidOid;

fabric_opt *options;

FabricFdwExecState *fmstate;

ListCell *lc;

Datum value = 0;

int n_params = 0;

void * returnValue;

bool first = true;

bool second = true;

char cmd [1024];

char info [1024];

FILE *fp;

foreignTableId = RelationGetRelid(rel);

fabric_get_options(foreignTableId);

options = fabric_get_options(foreignTableId);

fmstate = (FabricFdwExecState *) resultRelInfo->ri_FdwState;

n_params = list_length(fmstate->retrieved_attrs);

strcpy (cmd, “docker-compose -f /opt/gopath/src/github.com/hyperledger/fabric/examples/e2e_cli/docker-compose-test.yaml run –rm –no-deps cli peer chaincode invoke -o orderer.example.com:7050 –tls true –cafile /opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/ordererOrganizations/example.com/orderers/orderer.example.com/msp/tlscacerts/tlsca.example.com-cert.pem –logging-level CRITICAL -C “);

strcat (cmd, options->svr_channelname);

strcat (cmd, ” -n “);

strcat (cmd, options->svr_chaincodename);

strcat (cmd, ” -c ‘{”Args”:[“insert”,”);

strcpy (info, “{“);

foreach(lc, fmstate->retrieved_attrs)

{

int attnum = lfirst_int(lc) – 1;

char * colname = (char *) list_nth (fmstate->column_attrs, attnum);

bool *isnull = (bool*) palloc0(sizeof(bool) * n_params);

Oid type = slot->tts_tupleDescriptor->attrs[attnum]->atttypid;

value = slot_getattr(slot, attnum 1, &isnull[attnum]);

fabric_bind_sql_var(type, attnum, value, &isnull[attnum], &returnValue);

if (!first)

{

strcat (info, “,”);

}

else

{

strcat (cmd, “””);

strcat (cmd, (char *) returnValue);

strcat (cmd, “””);

strcat (cmd, MESSEPACHAR);

strcat (cmd, “””);

first = false;

}

strcat (info, “””);

strcat (info, colname);

strcat (info, “”:”);

strcat (info, “””);

strcat (info, (char *) returnValue);

strcat (info, “””);

}

strcat (info, “}”);

strcat (cmd, info);

strcat (cmd, “”]}’”);

fp = popen (cmd, “r”);

if (fp == NULL)

{

pclose (fp);

ereport(ERROR,

(errcode(ERRCODE_FDW_UNABLE_TO_CREATE_EXECUTION),

errmsg(“fail to exec: %s”, cmd)

));

}

return slot;

}