testcreate.c

电力与银行通讯的源码 1.应用tuxedo中间件. 2.与银行的前置机通讯. 3.proc*c 的应用

/*
	Create:创建用于测试的数据
*/
#include "public.h"
#ifdef __cplusplus
extern "C"
#endif
void
#ifdef MW_CICS
main(MW_SVCINFO * transb)
#endif
#ifdef MW_TUXEDO
MCREATE(MW_SVCINFO * transb)
#endif
{
#define MAX_ITEM 2000
	char szMsg[255];
	void *ppVar[2];
	char szSql[512];
	BOOL bRet;
	int nStatus = 0;
	unsigned char pParam[] = TYPE_CHAR TYPE_INT TYPE_INT;
	double dSumFee = 0;
	CMiddleWare mwMidWare;
	char szKHBH[MAX_ITEM][11];
	char szTemp[11] = "";
	int i=0;
	int nFileCount = 1;	//文件计数
	FILE *fp;
	char szFileName[20] = "Test1.Dat";
	MW_Init(&mwMidWare,transb);
	MW_AllocateString(&mwMidWare,1024); 
	memset(szKHBH,0,sizeof(szKHBH));
	ppVar[0] = szTemp;
	sprintf(szSql, "select distinct KHBH from C_DF ");
	if(!DB_SQLPrepare(&theDatabase, szSql, ppVar, 1))
	{
		sprintf(szMsg,"SQL = %s Prepare失败!",szSql);
		gf_Return(&mwMidWare,-1,szMsg);
		return;
	}
	sprintf(szFileName,"Test%d.Dat",nFileCount);
	fp = fopen(szFileName,"w");
	while(DB_SQLFetch(&theDatabase))
	{
		if(i==MAX_ITEM)	//写文件
		{
			fwrite(szKHBH,sizeof(char[11]),MAX_ITEM,fp);
			fclose(fp);
			nFileCount++;
			sprintf(szFileName,"Test%d.Dat",nFileCount);
			fp = fopen(szFileName,"w");
			i = 0;
		}
		strcpy(szKHBH[i],szTemp);
		i++;
	}
	fwrite(szKHBH,sizeof(char[11]),i ,fp);
	fclose(fp);
	DB_SQLDone(&theDatabase);
	gf_Return(&mwMidWare,0,"");
	return;
}