dafs_mysql.h

关于Mysql接口的简单的连接,插入,更新的操作,使用c语言实现

#ifndef H_DAFS_MYSQL
#define H_DAFS_MYSQL
#include<stdio.h>
#include<string.h>
#include<stdlib.h>
/* 包含SQL通讯区，它用于处理错误。*/
#include <windows.h>
#include <mysql.h>

#include "messDealDll.h"
#define NUM_USERNAME		10
#define NUM_PASSWORD		10
#define NUM_DBNAME			10
#define NUM_ERR_MSG			128

#define MAX_NUM_BUSSINESS	100
#define MAX_QM_NAME			48
#define MAX_QN_NAME			48
#define MAX_BUSSINESS_NO	15


/*审计级别定义*/
#define  HIGH 2
#define  LOW 1
#define AUDIT_LIST_MAX_SIZE 100
#define BLACK_LIST_MAX_SIZE 100
#define SERVER_MANAGE_LIST_MAX_SIZE 100

#define NODE_SIZE 30

#define  USER_LIST_SIZE 10
#define  USER_SIZE 30
/*-----结构体定义--------*/

typedef struct tagQM_QN{
	char	**QM;
	char	**QN;
	char	**CODE;
	int		num;
} QM_QN_PAIR, *PQM_QN_PAIR;


typedef struct tagDUBLQM_QN{
	char	msgRecvQM[48];
	char	msgRecvQN[48];
	char	ctlSendQM[48];
	char	ctlSendQN[48];
} RECV_SEND_PAIR,*PRECV_SEND_PAIR;

/*错误日志*/
typedef 
struct tag_sa_i_mistakelog {
	char code[15]; /*错误编号*/
	char mistakeType[30]; /*错误类型*/
	char dateCreate[32]; /*发生时间*/
	char description[200]; /*错误描述*/
	char measure[200]; /*采取措施*/
} TableMistakeLog,pTableMistackeLog;
/*登陆日志*/
typedef
struct tag_sa_i_srvstartlog
{
	char ipAddress[15];
	char netIdentifier[64];
	char operat[30];
	char paramet[200];
} SrvStartLog,*pSrvStartLog;




/*审计日志*/
typedef 
struct tag_sa_i_transfersdata
 {
	 MQMessBody mess;
	 char audittime[32];
	 int OverPass;
	 int ServerAudit; 
	 int ClientAudit;
	 int ContentAudit;
	 int OperatorAudit;
	 int islog;
	 int blackAudit;
	 int id;
 }TableAuditLog,*pTableAuditLog;
 
 /*黑名单*/
typedef 
struct black_node
{
	char blackNodeList[BLACK_LIST_MAX_SIZE][NODE_SIZE]; /*黑名单数组缓存*/
	int num; /*长度*/
} BlackList,*pBlackList;

 /*黑名单*/
 typedef 
	 struct tag_sa_i_blacklist
 {	
	 int active;
	 int alarm;
	 int alarmid;
	 char alarmtime[32];
	 char datecreated[32];
	 char machinename[32];
	 char ipaddress[30];
	 char macaddress[53];
	 char reason[200];
	 int transferid;
	 
 } TableBlackList,*pTableBlackList;
/*固定MQ数据*/
 typedef struct tag_i_config
 {
	 char qm_name[50]; /*发送队列管理器*/
	 char q_name[50]; /*发送队列*/
	 
	 char t_qm_name[50]; /*接收管理器*/
	 char t_q_name[50]; /*接收管理器*/
 } ChanlConfig,pChanlConfig;

 /* Thread Safety */
/*typedef MYSQL* MYSQL*;*/

/*综合审计结构体*/
typedef
struct tag_sa_i_auditNode
{
	char MQname[50]; /*管理器名*/
	char Qname[50]; /*队列名*/
	char CODE[15]; /*业务编号*/
			 
	char MachineName[32]; /*机器名*/
	char IpAddress[30]; /*IP地址*/
	char MacAddress[53]; /*Mac地址*/
	int	 isLog; /*是否记日志*/
	int AuditLevel; /*审计级别*/
	int srvId; /*用户ID*/
	unsigned int TransPort;/*端口号*/
	
} AuditNode,*pAuditNode;

/*用户管理信息*/
typedef 
struct tag_sa_i_srvManage {
	int srvimpId;
	char userList[USER_LIST_SIZE][USER_SIZE];
	int userListLen;
} SrvManage,*pSrvManage;

/*------------------------字段区------------------------------------*/
SrvManage srvManageList[SERVER_MANAGE_LIST_MAX_SIZE]; /*用户管理数组缓存*/
AuditNode auditNodeList[AUDIT_LIST_MAX_SIZE]; /*审计数据库数组缓存*/
ChanlConfig mqConfig; /*MQ配置信息缓存*/
BlackList blkList; /*黑名单缓存*/

int srvManage_lenght; /*用户管理数组缓存*/
int audit_lenght; /*审计数组缓存长度*/

/*建立一个线程上下文*/
void * create_thread_context(void * context);

#endif