java tbase_TBase应用接入指南(上篇)__版本号－－V2.17 更新日期：2019-11-13__PostgreSQL中文社区: 世界上功能最强大的开源数据库......

#include #include "libpq-fe.h"

int

main(int argc, char **argv){

const char *conninfo;

PGconn *conn;

PGresult *res;

const char *buffer = "1,tbasen2,pgxzn3,Tbase牛";

if (argc > 1){

conninfo = argv[1];

}else{

conninfo = "dbname = postgres";

}

conn = PQconnectdb(conninfo);

if (PQstatus(conn) != CONNECTION_OK){

fprintf(stderr, "连接数据库失败: %s",PQerrorMessage(conn));

}else{

printf("连接数据库成功！n");

}

res=PQexec(conn,"COPY tbase FROM STDIN DELIMITER ',';");

if(PQresultStatus(res) != PGRES_COPY_IN){

fprintf(stderr, "copy数据出错1: %s",PQresultErrorMessage(res));

}else{

int len = strlen(buffer);

if(PQputCopyData(conn,buffer,len) == 1){

if(PQputCopyEnd(conn,NULL) == 1){

res = PQgetResult(conn);

if(PQresultStatus(res) == PGRES_COMMAND_OK){

printf("copy数据成功！n");

}else{

fprintf(stderr, "copy数据出错2: %s",PQerrorMessage(conn));

}

}else{

fprintf(stderr, "copy数据出错3: %s",PQerrorMessage(conn));

}

}else{

fprintf(stderr, "copy数据出错4: %s",PQerrorMessage(conn));

}

}

PQclear(res);

PQfinish(conn);

return 0;

}

编译

gcc -c -I /usr/local/install/tbase_pgxz/include/ copy.c

gcc -o copy copy.o -L /usr/local/install/tbase_pgxz/lib/ -lpq

执行

./copy "dbname=postgres port=15432"

连接数据库成功！

copy数据成功！

```

### **3、shell脚本开发**

```

#!/bin/sh

if [ $# -ne 0 ]

then

echo "usage: $0 exec_sql"

exit 1

fi

exec_sql=$1

masters=`psql -h 172.16.0.29 -d postgres -p 15432 -t -c "select string_agg(node_host, ' ') from (select * from pgxc_node where node_type = 'D' order by node_name) t"`

port_list=`psql -h 172.16.0.29 -d postgres -p 15432 -t -c "select string_agg(node_port::text, ' ') from (select * from pgxc_node where node_type = 'D' order by node_name) t"`

node_cnt=`psql -h 172.16.0.29 -d postgres -p 15432 -t -c "select count(*) from pgxc_node where node_type = 'D'"`

masters=($masters)

ports=($port_list)

echo $node_cnt

flag=0

for((i=0;i