postgres嵌入式sql代码,C代码库,德仔网

代码语言
代码分类
【C】 postgres嵌入式sql
作者:白文 / 发布于2014/11/7/ 595

	1
	2
	3
	4
	5
	6
	7
	8
	9
	10
	11
	12
	13
	14
	15
	16
	17
	18
	19
	20
	21
	22
	23
	24
	25
	26
	27
	28
	29
	30
	31
	32
	33
	34
	35
	36
	37
	38
	39
	40
	41
	42
	43
	44
	45
	46
	47
	48
	49
	50
	51
	52
	53
	54
	55
	56
	57
	58
	59
	60
	61
	62
	63
	64
	65
	66
	67
	68
	69
	70
	71
	72
	73
	74
	75
	76
	77
	78
	79
	80
	81
	82
	83
	84
	85
	86
	87
	88
	89
	90
	/*
	
	ecpg test1.pgc
	gcc test1.c -o test1 -I /opt/PostgreSQL/9.3/include -L/opt/PostgreSQL/9.3/lib -lpq -lecpg
	
	*/
	#include <unistd.h>
	#include <stdlib.h>
	
	int main()
	{
	 int i;
	 char line[81];
	 EXEC SQL CONNECT TO your-db@localhost:5432 AS conn1 USER your-user USING your-passwd;
	
	 EXEC SQL BEGIN DECLARE SECTION;
	 int id;
	 int ind;
	 char name[33];
	 char create_table[]="CREATE TABLE test(id integer, name char(32))";
	 char drop_table[]="DROP TABLE test";
	 EXEC SQL END DECLARE SECTION;
	
	
	 EXEC SQL EXECUTE IMMEDIATE :drop_table;
	 EXEC SQL EXECUTE IMMEDIATE :create_table;
	 EXEC SQL COMMIT;
	
	 id = -1;
	 memset(name,0,sizeof(name));
	 EXEC SQL SELECT MAX(id) INTO :id :ind FROM test ;
	 if ( ind < 0 ) id = 0;
	 printf("max id=%d, ind=%d\n", id, ind);
	
	 for (i = 0; i < 10; i++)
	 {
	 id++;
	 sprintf(name, "test%02d", id);
	 EXEC SQL INSERT INTO test VALUES(:id, :name);
	 }
	 EXEC SQL COMMIT;
	
	 EXEC SQL DECLARE cr_test CURSOR FOR
	 SELECT id, name FROM test ORDER BY id;
	 EXEC SQL OPEN cr_test;
	
	 /*
	 EXEC SQL FETCH cr_test INTO :id, :name;
	 printf("state: %c%c%c%c%c code: %ld ", sqlca.sqlstate[0],
	 sqlca.sqlstate[1], sqlca.sqlstate[2],
	 sqlca.sqlstate[3], sqlca.sqlstate[4], sqlca.sqlcode);
	 printf("id->%d, name->%s\n", id, name);
	 */
	
	
	 for(i = 1; 1 ; i++ )
	 {
	 EXEC SQL FETCH NEXT FROM cr_test INTO :id, :name;
	
	 printf("state: %c%c%c%c%c code: %ld ", sqlca.sqlstate[0],
	 sqlca.sqlstate[1], sqlca.sqlstate[2],
	 sqlca.sqlstate[3], sqlca.sqlstate[4], sqlca.sqlcode);
	 if ( sqlca.sqlcode == 100 )break;
	 printf("%03d: id->%d, name->%s\n", i, id, name);
	 }
	
	
	 EXEC SQL CLOSE cr_test;
	
	
	 printf("\n");
	 while( fgets(line, 20, stdin) )
	 {
	 if ( strlen(line) == 0 ) break;
	 EXEC SQL BEGIN DECLARE SECTION;
	 char *stmt = "select id, name from test where id=?";
	 EXEC SQL END DECLARE SECTION;
	
	 id = atoi(line);
	 EXEC SQL PREPARE mystmt FROM :stmt;
	 EXEC SQL EXECUTE mystmt INTO :id, :name USING :id;
	 if ( sqlca.sqlcode != 100 )
	 {
	 printf("find id=%d, name=%s\n", id, name);
	 }
	 EXEC SQL DEALLOCATE PREPARE mystmt;
	 }
	
	 EXEC SQL DISCONNECT conn1;
	}
试试其它关键字
　嵌入式　
同语言下
可能有用的
白文贡献的其它代码(6)