ANSI实现动态 sql

 
/* 包含C头文件 */  
#include <stdio.h>  
#include <stdlib.h> 
#include <string.h>  
  
/* 包含SQLCA头文件 */  
#include <sqlca.h>  

/* 定义绑定变量值和 选择列表项值的最大长度 
 * 绑定变量：即在SQL语句中输入的“&”占位符。
 */ 
#define MAX_VAR_LEN     30 

/* 定义选择列表项名的最大长度 */  
#define MAX_NAME_LEN    31  
  

/* 定义宿主变量 */  
exec sql begin declare section; 
    char     *usrname = "scott";
    char     *passwd = "11";
    char     *serverid = "orcl"; 
  char sql_stat[100];  
  char current_date[20];  
exec sql end declare section;  
  
void sql_error(void);  
void connet(void);
void process_input(void);  
void process_output(void);  
  
int main(void)  
{  
    /* 安装错误处理句柄 */  
    exec sql whenever sqlerror do sql_error();  
  
    /* 连接到数据库 */  
    connet();  
  
    /* 
     * 分配输入描述区和输出描述区 
     * Ansi定义了该套标准，proc程序开发者按标准实现了它
     * 这两条语句在proc编译的时候会开辟对应大小的存储空间
     */  
    exec sql allocate descriptor 'input_descriptor';            //用来存储输入的宿主变量
    exec sql allocate descriptor 'output_descriptor';         //用来缓存数据库端返回的结果集 
  
    for( ; ; )  
    {  
        printf("
请输入动态SQL语句(EXIT:退出):
");  
        gets(sql_stat);  
  
        /* EXIT(exit)->退出 */  
        if(0 == strncmp(sql_stat , "EXIT" , 4) || 0 == strncmp(sql_stat , "exit" , 4))  
            break;  
  
        /* 准备动态SQL语句 */  
        exec sql prepare s from :sql_stat;  
  
        /* 定义游标 */  
        exec sql declare c cursor for s;  
  
        /* 处理绑定变量 ， 即处理占位符 “&” */  
        process_input();  
  
        /* 
         * 打开游标成功 意寓着结果已经被保存到输出描述区了。
         * select语句：处理查询结果 
         * 其他SQL语句：执行 
         */  
        exec sql open c using descriptor 'input_descriptor';  
        if(0 == strncmp(sql_stat , "SELECT" , 6) , 0 == strncmp(sql_stat , "select" , 6))  
        {  
                process_output();
        }  
        /* 关闭游标 */  
        exec sql close c;  
    }  
  
    /* 释放输入描述区和输出描述区 */  
    exec sql deallocate descriptor 'input_descriptor';  
    exec sql deallocate descriptor 'output_descriptor';  
  
    /* 提交事务，断开连接 */  
    exec sql commit work release;  
    puts("谢谢使用ANSI动态SQL!
");  
  
    return 0;  
}  
  
void sql_error(void)  
{  
    /* 显示SQL错误号、错误描述 */  
    printf("%.*s
" , sqlca.sqlerrm.sqlerrml , sqlca.sqlerrm.sqlerrmc);  
    exit(1);
}  
  
void process_input(void)  
{  
    int i;  
  
    /* 定义宿主变量 */  
    exec sql begin declare section;  
        int input_count;  
        int input_type ;  
        int input_len;  
        char input_buffer[MAX_VAR_LEN];  
        char name[MAX_NAME_LEN];  
        int occurs;  
    exec sql end declare section;  
  
    /* 绑定变量->输入描述区 */  
    exec sql describe input s using descriptor 'input_descriptor';  
  
    /* 取得绑定变量个数 */  
    exec sql get descriptor 'input_descriptor' :input_count = count;  
  
    /* 循环处理绑定变量名 */  
    for(i = 0 ; i != input_count ; ++i)  
    {  
        occurs = i + 1;  
  
        /* 取得绑定变量名 */  
        exec sql get descriptor 'input_descriptor' value :occurs :name = name;  
        printf("请输入%s的值：" , name);  
        gets(input_buffer);  
  
        /* 以NULL结尾 */  
        input_len = strlen(input_buffer);  
        input_buffer[input_len] = '';  
  
        /* 设置绑定变量类型、长度和值 */  
        input_type = 1;  
        exec sql set descriptor 'input_descriptor' value :occurs   
            type = :input_type , length = :input_len , data = :input_buffer;  
    }  
}  
  
void process_output(void)  
{  
    int i;  
  
    // 定义宿主变量  
    EXEC SQL BEGIN DECLARE SECTION ;  
        int output_count;  
        int output_type;  
        int output_len;  
        char output_buffer[MAX_VAR_LEN];
        short  output_indicator;  
        char name[MAX_NAME_LEN];  
        int occurs;  
    EXEC SQL END DECLARE SECTION ;  
  
    // 选择列表项->输出描述区 
    exec sql describe output s using descriptor 'output_descriptor';  
  
    //取得选择列表项个数  
    exec sql get descriptor 'output_descriptor' :output_count = count;  
  
    //循环处理选择列表项(即列名，或者叫表头) 
    
    output_type = 12;  //设置类型为变长字符串varchar
     
    for(i = 0 ; i != output_count ; ++i)  
    {  
        occurs = i + 1;  
        
        output_len = MAX_VAR_LEN;  
      
        // 设置选择列表项的类型和长度(设置每一列，按照varchar类型进行显示) 
        exec sql set descriptor 'output_descriptor' value :occurs   
                        type = :output_type , length = :output_len;  
  
        //取得选择列表项的名称并输出 
        exec sql get descriptor 'output_descriptor' value :occurs :name = name;  
            
        //显示选择列表项名称  
        printf("	%s" , name);  
    }  
    printf("
");  
  
    // 提取数据完毕->退出循环  
    exec sql whenever not found do break;  
  
    // 循环处理选择列表项数据  
    for( ; ; )  
    {  
        // 行数据-> fetch into 利用游标从输出描述区读取数据。 
        exec sql fetch c into descriptor 'output_descriptor';  
           
        // 循环处理每列数据  
        for(i = 0 ; i < output_count ; ++i)  
        {  
            occurs = i + 1;  
           
            // 取得列数据和指示变量值  
            exec sql get descriptor 'output_descriptor' VALUE :occurs  
                :output_buffer = DATA , :output_indicator = INDICATOR;  
  
            //输出列数据   
            if(-1 == output_indicator)  
               printf("	%s", "   ");         
            else  
               printf("	%s" , output_buffer);        
        }   
        printf("
"); 
    }  
}

void connet(void)
{
    int ret = 0;
    //连接数据库
    EXEC SQL CONNECT:usrname IDENTIFIED BY:passwd USING:serverid ;
    if (sqlca.sqlcode != 0)
    {
        ret = sqlca.sqlcode;
        printf("sqlca.sqlcode: err:%d 
", sqlca.sqlcode);
        return ;
    } else {
        printf("connect ok...
");
    }
}

1.ASNI 与 ORACLE 实现动态sql的最大区别就在于不用关心描述区的动态扩容，因为ASNI已经封装好了接口，直接调用就成。

2.也是主要分为两部分：输出描述区和输入描述区。两个区的作用同ORACLE 功能一样。

* 分配输入描述区和输出描述区
* Ansi 定义了该套标准，proc 程序开发者按标准实现了它
* 这两条语句在 proc 编译的时候会开辟对应大小的存储空间
*/
exec sql allocate descriptor 'input_descriptor'; //用来存储输入的宿主变量
exec sql allocate descriptor 'output_descriptor'; //用来缓存数据库端返回的结果集