⭐ 欢迎来到虫虫下载站！ | 📦 资源下载 📁 资源专辑 ℹ️ 关于我们
⭐ 虫虫下载站
📤 上传资源

📄 db.pc.not_sp

📁 linux 上http email 协议分析程序 主要能够处理大数据量的主干网的应用
💻 NOT_SP
📖 第 1 页 / 共 4 页
字号:
🔍
1234 
}

int CTblEmail::insRecord(STRU_TR_T_MAILFILE *prec)
{ 
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_MAILFILE rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));

	//EXEC SQL INSERT INTO TR_T_MAILFILE VALUES (:rec);
	EXEC SQL execute ins_TR_T_MAILFILE using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_MAILFILE [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_MAILFILE [%d]\n",sqlca.sqlcode);
		
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}

int CTblEmail::updateFileLen(int fileid,int filesize)
{
	EXEC SQL BEGIN DECLARE SECTION;

		int imlf_id;
		int imif_filesize;

	EXEC SQL END DECLARE SECTION;
	
	imlf_id=fileid;
	imif_filesize=filesize;	
	
	EXEC SQL UPDATE TR_T_MAILFILE SET MIF_FILESIZE=:imif_filesize WHERE MLF_ID=:imlf_id;
	
	if(checkSqlCode()!=0)
	{
		printf("UPDATE TR_T_MAILFILE SET MIF_FILESIZE[%d]\n",sqlca.sqlcode);
		TLog::toErr("UPDATE TR_T_MAILFILE SET MIF_FILESIZE[%d]\n",sqlca.sqlcode);
		
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}

int CTblEmail::updatespFileLen(int filesize)
{
	EXEC SQL BEGIN DECLARE SECTION;

		//int imlf_id;
		int imif_filesize;

	EXEC SQL END DECLARE SECTION;
	
	//imlf_id=fileid;
	imif_filesize=filesize;	
	
	EXEC SQL UPDATE TR_T_SPEMAILFILE SET SMF_FILESIZE=:imif_filesize WHERE SMF_FILESIZE=0;
	
	if(checkSqlCode()!=0)
	{
		printf("UPDATE TR_T_SPEMAILFILE SET SMF_FILESIZE[%d]\n",sqlca.sqlcode);
		TLog::toErr("UPDATE TR_T_SPEMAILFILE SET SMF_FILESIZE[%d]\n",sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}


int CTblEmail::insRecord(STRU_TR_T_MAILINFO *prec)
{ 
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_MAILINFO rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));

	//EXEC SQL INSERT INTO TR_T_MAILINFO VALUES (:rec);
	EXEC SQL execute ins_TR_T_MAILINFO using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_MAILINFO[%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_MAILINFO[%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]\n",prec->MIF_ID);
		TLog::toErr("[%d]\n",prec->MLF_ID);
		TLog::toErr("[%s]\n",prec->MIF_DATE);
		TLog::toErr("[%s]\n",prec->MIF_SUBJECT);
		TLog::toErr("[%d]\n",prec->MIF_PROTOCOL);
		TLog::toErr("[%s]\n",prec->MIF_CLIENTIP);
		TLog::toErr("[%s]\n",prec->MIF_SERVERIP);
		TLog::toErr("[%s]\n",prec->MIF_CAPTIME);
		TLog::toErr("[%s]\n",prec->MIF_CLNTLOCATION);
		TLog::toErr("[%s]\n",prec->MIF_CLNTACCOUNT);
		TLog::toErr("[%s]\n",prec->MIF_CLNTCALLID);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}

int CTblEmail::insRecord(STRU_TR_T_MAILADDRESS *prec)
{ 
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_MAILADDRESS rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_MAILADDRESS using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_MAILADDRESS[%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_MAILADDRESS[%d]\n",sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}

int CTblEmail::insRecord(STRU_TR_T_MAILTEXT *prec)
{	
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_MAILTEXT rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_MAILTEXT using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_MAILTEXT[%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_MAILTEXT[%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]\n",rec.MTX_ID );
   		TLog::toErr("[%d]\n",rec.MIF_ID);
   		TLog::toErr("[%s]\n",rec.MTX_CONTENTTYPE);
   		TLog::toErr("[%s]\n",rec.MTX_CHARSET);
   		TLog::toErr("[%s]\n",rec.MTX_TEXTBODY);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}

int CTblEmail::insRecord(STRU_TR_T_SPEMAILFILE *prec)
{ 
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SPEMAILFILE rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_SPEMAILFILE using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_SPEMAILFILE [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_SPEMAILFILE [%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]",rec.SMF_ID);
   		TLog::toErr("[%s]",rec.SMF_ORIGINALFILE);
   		TLog::toErr("[%d]",rec.SMF_FILEBEGIN);
   		TLog::toErr("[%d]",rec.SMF_FILESIZE);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}

int CTblEmail::insRecord(STRU_TR_T_SPEMAILINFO *prec)
{ 
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SPEMAILINFO rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_SPEMAILINFO using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_SPEMAILINFO [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_SPEMAILINFO [%d]\n",sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}

int CTblEmail::insRecord(STRU_TR_T_SPEMAILADDRESS *prec)
{ 
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SPEMAILADDRESS rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_SPEMAILADDRESS using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_SPEMAILADDRESS [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_SPEMAILADDRESS [%d]\n",sqlca.sqlcode);
		
		TLog::toErr("[%d]",rec.SMA_ID);
   		TLog::toErr("[%d]",rec.SMI_ID);
   		TLog::toErr("[%d]",rec.SMA_MAILROLE);
   		TLog::toErr("[%s]",rec.SMA_SHOWNAME);
   		TLog::toErr("[%s]",rec.SMA_ADDRESS);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}

int CTblEmail::insRecord(STRU_TR_T_SPEMAILTEXT *prec)
{ 
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SPEMAILTEXT rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_SPEMAILTEXT using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_SPEMAILTEXT [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_SPEMAILTEXT [%d]\n",sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}



CTblEmail::CTblEmail()
{
	prepare();
}

CTblEmail::~CTblEmail()
{
}

CTblWebApp::CTblWebApp()
{
	m_bcur_TR_T_SUBMITRULE=false;
	m_bcur_TR_T_WEBMONRULE=false;
	m_bcur_TR_T_SUBMITRULE1=false;
	

}
CTblWebApp::~CTblWebApp()
{
	
	
}

CTblWeb::CTblWeb()
{
	prepare();
}

CTblWeb::~CTblWeb()
{
	
}

void CTblWeb::updateSUBMIT(int id)
{
	EXEC SQL BEGIN DECLARE SECTION;

		int ispg_id;
		int isubmit;

	EXEC SQL END DECLARE SECTION;
	
	ispg_id=id;
	isubmit=1;
	EXEC SQL UPDATE TR_T_SENPAGE SET SPG_HASSUBMIT=:isubmit WHERE SPG_ID=:ispg_id;
	
	if(checkSqlCode()!=0)
	{
		printf("IUPDATE TR_T_SENPAGE  errcode=[%d] spd_id=[%d]\n",sqlca.sqlcode,ispg_id);
	
		TLog::toErr("IUPDATE TR_T_SENPAGE  errcode=[%d] spd_id=[%d]\n",sqlca.sqlcode,ispg_id);
	}
	
}


void 	CTblWeb::prepare()
{
	EXEC SQL BEGIN DECLARE SECTION;
		char c_sql[512];
	EXEC SQL END DECLARE SECTION;

	strcpy(c_sql, "INSERT INTO TR_T_SENPAGE VALUES (:v1,:v2,:v3,:v4,:v5,:v6,:v7,:v8,:v9,:v10,:v11,:v12,:v13,:v14,:v15)");
	EXEC SQL PREPARE ins_TR_T_SENPAGE from :c_sql;  
	if(checkSqlCode()!=0)
	{
		TLog::toErr("prepare [%s] [%d]\n",c_sql,sqlca.sqlcode);
	}
		
	strcpy(c_sql, "INSERT INTO TR_T_SUBMITCONTENT VALUES (:v1,:v2,:v3,:v4)");
	EXEC SQL PREPARE ins_TR_T_SUBMITCONTENT from :c_sql;  
	if(checkSqlCode()!=0)
	{
		TLog::toErr("prepare [%s] [%d]\n",c_sql,sqlca.sqlcode);
	}
}

int CTblWeb::insRecord(STRU_TR_T_SENPAGE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SENPAGE rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_SENPAGE using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_SENPAGE [%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]", prec->SPG_ID);
		TLog::toErr("[%d]", prec->ACT_ID);
		TLog::toErr("[%d]", prec->WAP_ID);
		TLog::toErr("[%s]", prec->SPG_CLIENTIP);
		TLog::toErr("[%s]", prec->SPG_SERVERIP);
		TLog::toErr("[%s]", prec->SPG_DOMAINNAME);
		TLog::toErr("[%s]", prec->SPG_CAPTIME);
		TLog::toErr("[%d]", prec->SPG_DATAFLOW);
		TLog::toErr("[%s]", prec->SPG_CLNTLOCATION);
		TLog::toErr("[%s]", prec->SPG_CLNTACCOUNT);
		TLog::toErr("[%s]", prec->SPG_CLNTCALLID);
		TLog::toErr("[%s]", prec->SPG_PAGECONTENT);		
		TLog::toErr("INSERT INTO TR_T_SENPAGE [%d]\n",sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;

}
int CTblWeb::insRecord(STRU_TR_T_SUBMITCONTENT *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SUBMITCONTENT rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_SUBMITCONTENT using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_SUBMITCONTENT [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_SUBMITCONTENT [%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]",rec.SBC_ID);
		TLog::toErr("[%d]",rec.SPG_ID);
		TLog::toErr("[%s]",rec.SBC_FIELDNAME);
		TLog::toErr("[%s]",rec.SBC_FIELDVALUE);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;
}

int CTblWebApp::totCount_TR_T_SUBMITRULE()
{
	EXEC SQL BEGIN DECLARE SECTION;

		long totrec=0;

	EXEC SQL END DECLARE SECTION;


	EXEC SQL select count(*) into :totrec from TR_T_SUBMITRULE;
	if(checkSqlCode()!=0)
	{
		printf("select count(*) from TR_T_SUBMITRULE [%d]\n",sqlca.sqlcode);
		TLog::toErr("select count(*) from TR_T_SUBMITRULE [%d]\n",sqlca.sqlcode);
	}
	if(sqlca.sqlcode<0)
		return (sqlca.sqlcode);
		
	return totrec;

}

int CTblWebApp::totCount_TR_T_SUBMITRULE(int id)
{
	EXEC SQL BEGIN DECLARE SECTION;

		long totrec=0;
		int wmr_id;		

	EXEC SQL END DECLARE SECTION;
	
	wmr_id=id;

	EXEC SQL select count(*) into :totrec from TR_T_SUBMITRULE WHERE WMR_ID=:wmr_id;
	if(checkSqlCode()!=0)
	{
		printf("select count(*) from TR_T_SUBMITRULE WHERE [%d]\n",sqlca.sqlcode);
		TLog::toErr("select count(*) from TR_T_SUBMITRULE WHERE [%d]\n",sqlca.sqlcode);
	}
	if(sqlca.sqlcode<0)
		return (sqlca.sqlcode);
		
	return totrec;
}


int CTblWebApp::totCount_TR_T_WEBMONRULE()
{
	EXEC SQL BEGIN DECLARE SECTION;

		long totrec=0;

	EXEC SQL END DECLARE SECTION;


	EXEC SQL select count(*) into :totrec from TR_T_WEBMONRULE;
	if(checkSqlCode()!=0)
	{
		printf("select count(*)  from TR_T_WEBMONRULE[%d]\n",sqlca.sqlcode);
		TLog::toErr("select count(*)  from TR_T_WEBMONRULE[%d]\n",sqlca.sqlcode);
	}
	if(sqlca.sqlcode<0)
		return (sqlca.sqlcode);
		
	return totrec;
}
	
int CTblWebApp::fetchRecord(STRU_TR_T_SUBMITRULE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SUBMITRULE rec;

	EXEC SQL END DECLARE SECTION;
	
	if(!m_bcur_TR_T_SUBMITRULE)
	{
		EXEC SQL declare cur_TR_T_SUBMITRULE cursor for select * from TR_T_SUBMITRULE;
		EXEC SQL open cur_TR_T_SUBMITRULE;
		m_bcur_TR_T_SUBMITRULE=true;
	}
	
	EXEC SQL fetch cur_TR_T_SUBMITRULE into :rec;
	
	if(checkSqlCode()!=0)
	{
		printf("fetch cur_TR_T_SUBMITRULE  [%d]\n",sqlca.sqlcode);
		TLog::toErr("fetch cur_TR_T_SUBMITRULE  [%d]\n",sqlca.sqlcode);
	}
	if(checkSqlCode()!=0)
	{
		EXEC SQL close cur_TR_T_SUBMITRULE;
		m_bcur_TR_T_SUBMITRULE=false;
		return sqlca.sqlcode;	
	}

	memcpy((char *)(void *)prec,(char *)(void *)&rec,sizeof(rec));

	return sqlca.sqlcode;

}

int CTblWebApp::fetchRecord(STRU_TR_T_SUBMITRULE *prec, int _wmr_id)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SUBMITRULE rec;
		int wmr_id;

	EXEC SQL END DECLARE SECTION;
	
	wmr_id=_wmr_id;
	if(!m_bcur_TR_T_SUBMITRULE1)
	{
		printf("open cur=%d\n",wmr_id);
		EXEC SQL declare cur_TR_T_SUBMITRULE1 cursor for select * from TR_T_SUBMITRULE WHERE WMR_ID=:wmr_id;
		EXEC SQL open cur_TR_T_SUBMITRULE1;
		m_bcur_TR_T_SUBMITRULE1=true;
	}
	
	EXEC SQL fetch cur_TR_T_SUBMITRULE1 into :rec;
	
	if(checkSqlCode()!=0)
	{
		printf("fetch cur_TR_T_SUBMITRULE1  [%d]\n",sqlca.sqlcode);
		TLog::toErr("fetch cur_TR_T_SUBMITRULE1  [%d]\n",sqlca.sqlcode);
	}
	if(checkSqlCode()!=0)
	{
		EXEC SQL close cur_TR_T_SUBMITRULE1;
		m_bcur_TR_T_SUBMITRULE1=false;
		return sqlca.sqlcode;	
	}

	memcpy((char *)(void *)prec,(char *)(void *)&rec,sizeof(rec));

	return sqlca.sqlcode;

}



int CTblWebApp::fetchRecord(STRU_TR_T_WEBMONRULE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_WEBMONRULE rec;

	EXEC SQL END DECLARE SECTION;
	
	if(!m_bcur_TR_T_WEBMONRULE)
	{
		EXEC SQL declare cur_TR_T_WEBMONRULE cursor for select * from TR_T_WEBMONRULE;
		EXEC SQL open cur_TR_T_WEBMONRULE;
		m_bcur_TR_T_WEBMONRULE=true;
	}
	
	EXEC SQL fetch cur_TR_T_WEBMONRULE into :rec;
	
	if(checkSqlCode()!=0)
	{
		printf("fetch cur_TR_T_WEBMONRULE  [%d]\n",sqlca.sqlcode);
		TLog::toErr("fetch cur_TR_T_WEBMONRULE  [%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]\n",rec.WMR_ID);
   	TLog::toErr("[%d]\n",rec.ACT_ID);
   	TLog::toErr("[%d]\n",rec.WAP_ID);
   	TLog::toErr("[%s]\n",rec.WMR_URLFEATURE);
   	TLog::toErr("[%d]\n",rec.WMR_DATAFLOW);
		
	}
	if(checkSqlCode()!=0)
1234

⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -