学步园

代码：xx.pc

/* 
    功能：演示了Oracle滚动游标进行更新(或删除)操作
 
    定义游标时注意事项： 
    1. DECLARE CURSOR语句必须是使用游标的第一条语句 
    2. 游标名称是一个标识符，而不是宿主变量，其长度是可以任意的，但只有前31个字符有效 
    3. 游标所对应的SELECT语句不能包含INTO子句 
    4. 游标语句(DECLARE,OPEN,FETCH,CLOSE)必须在同一个预编译单元内 
*/  
#include <stdio.h>   
#include <string.h>   
#include <stdlib.h>   
  
#include <sqlca.h>   
#pragma comment(lib, "orasql10.lib")
  
int connect();  
void cursor();  
void sql_error();  
  
void main()  
{  
    EXEC SQL WHENEVER SQLERROR DO sql_error();  // 安装错误处理句柄   
    if(connect() == 0)  
    {  
        cursor();  
        EXEC SQL COMMIT RELEASE;                // 提交事务，断开连接   
    }  
    else  
        printf("连接失败\n");  
}  
  
int connect()                   // connect to oracle database   
{  
    char username[10], password[10], server[10];  
  
    strcpy(username, "scott");  
    strcpy(password, "scott");  
    strcpy(server, "orcl");  
  
    EXEC SQL CONNECT :username IDENTIFIED BY :password USING :server;
  
    if(sqlca.sqlcode == 0)  
        return 0;  
    else  
        return sqlca.sqlcode;  
}  
  
void sql_error()                // print error infomation   
{  
    printf("%.*s\n", sqlca.sqlerrm.sqlerrml, sqlca.sqlerrm.sqlerrmc);  
}  
  
void cursor()                   // 游标操作   
{  
    int eno;                    // 定义宿主变量   
    char name[10], action;  
    float salary;  
  
    EXEC SQL DECLARE emp_cursor SCROLL CURSOR FOR Select empno, ename, sal from emp FOR UPDATE;    // 定义游标用于更新(或删除)   
    EXEC SQL OPEN emp_cursor;   // 打开游标   
    EXEC SQL WHENEVER NOT FOUND DO BREAK;   // 游标数据提取完毕后退出循环   
    for(;    
    {  
        printf("\nF: 第一行，P：前一行，N：下一行，L：最后一行\n");  
        printf("C: 当前行，X：退出\n请输入具体操作：");  
        scanf("%c", &action);  
        fflush(stdin);  
  
        switch(action)  
        {  
        case 'F':  
        case 'f':  
            EXEC SQL FETCH FIRST emp_cursor into :eno, :name, :salary;  
            break;  
        case 'P':  
        case 'p':  
            EXEC SQL FETCH PRIOR emp_cursor into :eno, :name, :salary;  
            break;  
        case 'N':  
        case 'n':  
            EXEC SQL FETCH NEXT emp_cursor into :eno, :name, :salary;  
            break;  
        case 'L':  
        case 'l':  
            EXEC SQL FETCH LAST emp_cursor into :eno, :name, :salary;  
            break;  
        case 'C':  
        case 'c':  
            EXEC SQL FETCH CURRENT emp_cursor into :eno, :name, :salary;  
            break;  
        case 'X':  
        case 'x':  
            EXEC SQL CLOSE emp_cursor;  
            return;  
        }  
        
		if(salary < 2000)
		{
			EXEC SQL UPDATE emp set comm=:salary*0.1 where CURRENT of emp_cursor;		// 使用游标更新当前行
			printf("name: %s, 工资: %4.0f, 补助: %6.2f\n", name, salary, salary * 0.1);
		}
		else
			printf("name = %s(%d), salary = %4.0f\n", name, strlen(name), salary);
    }  
  
    printf("sqlca.sqlerrd[2] = %d\n", sqlca.sqlerrd[2]);        // sqlca.sqlerrd[2]存放着Select语句作用的行数   
}