Makefile
.SUFFIXES: .c .oCC=gccPROC=procPROCSRCS=oracle.pcDBSRCS=$(PROCSRCS:.pc=.c)SRCS=main.c\$(DBSRCS)OBJS=$(SRCS:.c=.o)ORACLE_HOME=/opt/oracle/product/11.2.0ORAFLAGS1=/usr/include/linuxORAFLAGS2=/usr/lib/gcc/i686-redhat-linux/4.4.4/includeEXEC=myoracleall: $(OBJS)$(CC) -L${ORACLE_HOME}/lib -lclntsh -o $(EXEC) $(OBJS) @echo '^_^ ^_^ ^_^ ^_^ ^_^ ^_^ OK ^_^ ^_^ ^_^ ^_^ ^_^ ^_^'.c.o: $(DBSRCS)$(CC) -Wall -g -o $@ -c $<$(DBSRCS):$(PROC) INAME=$(PROCSRCS) INCLUDE=$(ORAFLAGS1) INCLUDE=$(ORAFLAGS2) CPOOL=YES MODE=ANSI CODE=ANSI_C PARSE=PARTIAL THREADS=YES ONAME=$(DBSRCS)clean:rm -f $(OBJS)rm -f $(DBSRCS)oracle.h#ifndef ORACLE_H_#define ORACLE_H_void sql_error();//打印错误信息void sql_init();//初始化oracleint sql_connect(const char *User, const char *Password, const char *DBName);//连接到oracleint sql_exec(const char *DySQL);//执行非select SQL语句int sql_commit();//提交事务int sql_rollback();//回滚事务int sql_open(const char *DySQL);//执行select SQL语句int sql_disconnect();//断开连接int sql_free();//释放资源#endif /* ORACLE_H_ */oracle.pc
涉及到具体逻辑的时候，只需要将printf的地方修改为逻辑处理
#include <stdio.h>#include <stdlib.h>#include <string.h>#ifdef __cplusplusextern "C"{#endifvoid sqlglmt(void*, char*, size_t*, size_t* ); #ifdef __cplusplus}#endif//嵌入式SQL中使用的变量，必须再EXEC SQL BEGIN DECLARE SECTION申明EXEC SQL BEGIN DECLARE SECTION; sql_context pContext;long SQLCODE;EXEC SQL END DECLARE SECTION;void sql_error()//打印错误信息{char sErrorString[512];//定义一个buf，存放错误描述size_t tMessageSize = 0;size_t tErrorSize = sizeof(sErrorString);memset(sErrorString, 0, sizeof(sErrorString));sqlglmt(pContext, sErrorString, &tErrorSize, &tMessageSize);//调用oracle的api函数得到错误信息sErrorString[tMessageSize] = 0;printf("%s\n", sErrorString);//打印错误信息}void sql_init()//初始化oracle{SQLCODE = 0;pContext = NULL;//如果proc的THREADS=YES，那么proc程序第一条嵌入SQL语句就应该是EXEC SQL ENABLE THREADSEXEC SQL ENABLE THREADS;//分配资源EXEC SQL CONTEXT ALLOCATE :pContext;//使用资源EXEC SQL CONTEXT USE :pContext;}int sql_connect(const char *User, const char *Password, const char *DBName)//连接到oracle{EXEC SQL BEGIN DECLARE SECTION;const char *sUser;const char *sPassword;const char *sServer;EXEC SQL END DECLARE SECTION;SQLCODE = 0;sUser = User;//连接oracle的用户名sPassword = Password;//连接oracle的密码sServer = DBName;//连接oracle的数据库名EXEC SQL CONNECT :sUser IDENTIFIED BY :sPassword USING :sServer;//连接到oracle的嵌入式SQLif (SQLCODE != 0)//如果SQLCODE ！= 0代表连接失败{sql_error();return 1;}else{return 0;}}int sql_exec(const char *DySQL)//执行非select SQL语句{EXEC SQL BEGIN DECLARE SECTION; const char *sDySQL;EXEC SQL END DECLARE SECTION;SQLCODE = 0;sDySQL = DySQL;EXEC SQL EXECUTE IMMEDIATE :sDySQL;//执行非select SQL语句if (SQLCODE != 0)//如果SQLCODE ！= 0代表执行失败{sql_error();return 1;}else{return 0;}}int sql_commit()//提交事务{SQLCODE = 0;EXEC SQL COMMIT WORK;if (SQLCODE != 0){sql_error();return 1;}else{return 0;}}int sql_rollback()//回滚事务{SQLCODE = 0;EXEC SQL ROLLBACK WORK;if (SQLCODE != 0){sql_error();return 1;}else{return 0;}}int sql_open(const char *DySQL)//执行select SQL语句{EXEC SQL BEGIN DECLARE SECTION;int i, iOutput_count, iOccurs, iType, iLen;short iInd;char sName[1024];//存放SELECT语句查询到的字段名char sData[1024];//存放SELECT语句查询到的字段值char sOutput[64];char sInput[64];const char *sDySQL;EXEC SQL END DECLARE SECTION;SQLCODE = 0;sDySQL = DySQL;sprintf(sOutput, "output%p", pContext);//格式化一个进程唯一不重复的字符串sprintf(sInput, "input%p", pContext);//格式化一个进程唯一不重复的字符串EXEC SQL ALLOCATE DESCRIPTOR :sOutput;//分配输出缓冲区EXEC SQL ALLOCATE DESCRIPTOR :sInput;//分配输入缓冲区EXEC SQL PREPARE S FROM :sDySQL;//准备执行sDySQL指定的SELECT语句if (SQLCODE != 0)//如果SQLCODE ！= 0代表执行失败{sql_error();EXEC SQL DEALLOCATE DESCRIPTOR :sInput;//释放输出缓冲区EXEC SQL DEALLOCATE DESCRIPTOR :sOutput;//释放输入缓冲区return 1;}EXEC SQL DECLARE C CURSOR FOR S;//申请一个游标，名为CEXEC SQL OPEN C USING DESCRIPTOR :sInput;//打开游标CEXEC SQL DESCRIBE OUTPUT S USING DESCRIPTOR :sOutput;//选择输出区域EXEC SQL GET DESCRIPTOR :sOutput :iOutput_count = COUNT;//取得选择列表的个数，放入变量iOutput_count当中for(i=0;i<iOutput_count;i++)//循环遍历字段，将所有字段名输出到屏幕{memset(sData, 0, sizeof(sData));memset(sName, 0, sizeof(sName));//得到SELECT语句查询返回的字段描述//sName中存放查询到的字段名，iType中存放字段类型，iLen中存放字段长度iOccurs = i + 1;//GET DESCRIPTOR语句中字段是从1开始的，所以iOccurs要从1开始执行EXEC SQL GET DESCRIPTOR :sOutputVALUE :iOccurs :iType = TYPE, :iLen = LENGTH, :sName = NAME;printf("%s\t", sName);//在屏幕打印字段名称iType = 12;//设置字段为字符串类型iLen = sizeof(sData);//设置接收字段返回值buffer最大长度为sizeof(sData)EXEC SQL SET DESCRIPTOR :sOutputVALUE :iOccurs TYPE = :iType, LENGTH = :iLen;}printf("\n");//字段名打印完毕，在屏幕上打印一个回车符EXEC SQL WHENEVER NOT FOUND DO BREAK;while(1)//循环遍历所有行，将行中所有字段值输出到屏幕{/*行数据，输出描述区*/ EXEC SQL FETCH C INTO DESCRIPTOR :sOutput;//得到一行记录for(i=0;i < iOutput_count;i++)//循环遍历一行记录中的每一个字段{iOccurs = i + 1;memset(sData, 0, sizeof(sData));iInd = 0;EXEC SQL GET DESCRIPTOR :sOutputVALUE :iOccurs :sData = DATA, :iInd = INDICATOR;if (iInd == -1)//如果字段中有NULL值，iInd == -1{printf("%s\t", "NULL");}else{printf("%s\t", sData);}}printf("\n");//一行记录打印完毕，在屏幕上打印一个回车符}EXEC SQL CLOSE C;//关闭游标CEXEC SQL DEALLOCATE DESCRIPTOR :sOutput;//释放输出缓冲区EXEC SQL DEALLOCATE DESCRIPTOR :sInput;//释放输入缓冲区return 0;}int sql_disconnect()//断开连接{SQLCODE = 0;EXEC SQL ROLLBACK WORK RELEASE;//断开连接，回滚事务//EXEC SQL COMMIT WORK RELEASE;//断开连接，提交事务if (SQLCODE != 0){sql_error();return 1;}else{return 0;}}int sql_free()//释放资源{SQLCODE = 0;EXEC SQL CONTEXT FREE :pContext;if (SQLCODE != 0){sql_error();return 1;}else{return 0;}}main.c 用于测试#include "oracle.h"int main(){sql_init();//初始化数据库sql_connect("dbuser1", "dbuser1", "orcl");//连接到oracle//sql_exec("insert into table1 (id, name) values (1, '测试')");//执行非SELECT的SQL语句sql_open("select * from table1");//执行SELECT SQL语句//sql_commit();//提交事务//sql_rollback();//回滚事务sql_disconnect();//断开连接sql_free();//释放资源return 0;}如果更改为cpp, 修改makefile 文件.SUFFIXES: .cpp .oCC=g++PROC=procPROCSRCS=oracle.pcDBSRCS=$(PROCSRCS:.pc=.cpp)SRCS=main.cpp\$(DBSRCS)OBJS=$(SRCS:.cpp=.o)ORACLE_HOME=/opt/oracle/product/11.2.0ORAFLAGS1=/usr/include/linuxORAFLAGS2=/usr/lib/gcc/i686-redhat-linux/4.4.4/includeEXEC=myoracleall: $(OBJS)$(CC) -L${ORACLE_HOME}/lib -lclntsh -o $(EXEC) $(OBJS) @echo '^_^ ^_^ ^_^ ^_^ ^_^ ^_^ OK ^_^ ^_^ ^_^ ^_^ ^_^ ^_^'.cpp.o: $(DBSRCS)$(CC) -Wall -g -o $@ -c $<$(DBSRCS):$(PROC) INAME=$(PROCSRCS) INCLUDE=$(ORAFLAGS1) INCLUDE=$(ORAFLAGS2) CPOOL=YES MODE=ANSI CODE=CPP PARSE=PARTIAL THREADS=YES ONAME=$(DBSRCS)clean:rm -f $(OBJS)rm -f $(DBSRCS)
，并且如此真实的活着——这，就是旅行的意义。
