#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sqlca.h>
void connect();
void sql_err();void cursor();
void main()
{
EXEC SQL WHENEVER SQLERROR DO sql_err();
connect();
cursor();
EXEC SQL COMMIT RELEASE;
}
void sql_err()
{
printf("%.*s\n",sqlca.sqlerrm.sqlerrml,,sqlca.sqlerrm.sqlerrmc);
}
void connect()/*数据库连接-本地数据库，不添加server*/
{
EXEC SQL BEGIN DECLARE SECTION;
char username[20],password[20];
EXEC SQL END DECLARE SECTION;
printf("input username: ");
gets(username);
printf("input password: ");
gets(password);
EXEC SQL CONNECT :username IDENTIFIED BY :password;
}
void cursor()/*游标的标准使用方式，声明，打开，抓取，关闭*/
{
EXEC SQL BEGIN DECLARE SECTION;
int dno;
char name[20];
float salary;
sql_cursor emp_cursor;
EXEC SQL END DECLARE SECTION;
printf("input dept no: ");
scanf("%d",&dno);
EXEC SQL ALLOCATE :emp_cursor;
EXEC SQL EXECUTE
BEGIN
OPEN :emp_cursor FOR SELECt ename,sal FROM emp WHERE deptno=:dno;
END;
END-EXEC;
EXEC SQL WHENEVER NOT FOUND DO BREAK;
while(1)
{
EXEC SQL FETCH :emp_cursor INTO :name,:salary;
printf("name: %s,salary: %f\n",name,salary);
}
EXEC SQL CLOSE :emp_cursor;
EXEC SQL FREE :emp_cursor;
}
运行结果：
