sql.pc

程序实现了在ip协议之上加一层RUDP协议

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sqlda.h>
#include <sqlcpr.h>


/*先是.pc,编译成.c之后,里面的方法可以被其它文件调用*/
  EXEC SQL BEGIN DECLARE SECTION;
	char		username[20];
	char		password[20];
	char		service[20];
 	/*int		EquipId[50];*/		/*在数据库中equipid是number(5,0) 一列多条记录用二维数组*/
	/*char		EquipType[50];*/ 		/*设备类型 包发送的时候需要知道设备类型*/
	int		id,count;		/*count表示记录的条数.*/
  int		length;		/*返回的指针长度*/
  EXEC SQL END DECLARE SECTION;
  EXEC SQL INCLUDE SQLCA;
  EXEC SQL INCLUDE ORACA;
  EXEC SQL INCLUDE SQLDA;

struct 
{
    int EquipId[50];
    char EquipType[50][50];
    long EquipIP[50]; 
}EquipData;

int sql_error()
{
	/*写日志文件*/
	return 0; 		/*当连接失败的时候返回0*/
}

int ConnDB() /*与数据库建立连接*/
{
  int result=1;
  strcpy(username,"MobiOne"); /*数据库用户名*/
  strcpy(password,"reesion"); /*数据库密码*/
  strcpy(service,"ora10"); /*数据库密码*/
  EXEC SQL CONNECT :username IDENTIFIED BY :password using :service;
  EXEC SQL WHENEVER SQLERROR DO sql_error();

  return result; /* 0表示数据库连接成功 还没考虑DB连接失败的*/
}

/*读相应的表,取出具体内容.读出来的设备信息应该放在全局变量中,供包发送的时候用*/
int SelectEquipTable(int EquipId[],char EquipType[],long EquipIP[]) 
{
       EXEC SQL DECLARE c1 CURSOR FOR
       SELECT EQUIPID,EQUIPTYPE,EQUIPIP FROM LOCALEQUIP;
	EXEC SQL OPEN c1;
	EXEC SQL FETCH c1	into :EquipData;
	 	 if(sqlca.sqlcode!=0&&sqlca.sqlcode!=100&&sqlca.sqlcode!=1403)
		 {
			 return 0; 	/*查询失败*/
		 }
		 count=sqlca.sqlerrd[2]; 	/*总共有多少条记录*/
		
		 for(id=0;id<count;id++)
		 {
			
		       EXEC SQL FETCH c1 INTO :EquipData; 
			EquipId[id]=EquipData.EquipId[id];					
			EquipType[id]=EquipData.EquipType[id][0];
                    EquipIP[id]= EquipData.EquipIP[id];


		 }
		 EXEC SQL CLOSE c1;
	return 1;
}