dbfunc.c

UNIX/LINUX平台下面SMS网管原代码

# line 866 "/usr/agent/incl/bms_sql.h"


#endif
# line 15 "dbfunc.cp"




void error_handler();
void warning_handler();
void notfound_handler();

int  DB_connectDB(char *uid, char *pwd, char *svc);
void DB_closeDB();
void DB_Commit();
void DB_Rollback();

int  DB_search_pin(char *sname, short *ictype,char *icno, char *pin, char *cid);
int  DB_reset_pin(char *cid, short bid, char *pin);
int  DB_search_acct(char *acct, char *cid, char *aid, int type);
int  DB_check_bid_scope(char *cid, char *acct, short bid);
int  DB_check_broker( char *cid, short bid, int *st);
int  DB_check_co_pwd( char *cid, short bid, char *cpwd);
int  DB_add_broker_err(char *cid,int bid);
int  DB_reset_broker_err(char *cid,short bid);
int  DB_search_ps_acc_info( PS_ACCINFO *pS_aCcinfo);
int  DB_add_ps_err(char *cid);
int  DB_reset_ps_err(char *cid);
int  DB_search_ps_acct_by_tail(char *account, char *cid, char *tail);
int  DB_search_co_acct_by_tail(char *account, char *cid, char *tail);
int  DB_search_transfer_account(char *name, char *account, char *cid, char *inacc, char *tail);
int  DB_seek_acc_link(int *rowcount, char *cid, char *filename);
int  DB_seek_limit(double *aggr_amt, double *max_limit, char *cid, char *account);
int	 DB_search_person_info(int type, char *sonsign_no, char *cid) ;
int  DB_search_co_acct(char *acct, char *cid, char *aid);

extern char uid[32], pwd[32], svc[32];

void error_handler()
{
	bms_trace("SQLCODE = %d", sqlca.sqlcode);

	if (sqlca.sqlerrm.sqlerrml)
	{
		bms_trace("SQL Server Error:");
		bms_trace("%s\n\n", sqlca.sqlerrm.sqlerrmc);
	}

	if ( sqlca.sqlcode == -33620271 ) {
		DB_closeDB() ;
		sleep( 1) ;

		if ( DB_connectDB(uid, pwd, svc) < SUCCESS ) 
		{
			bms_trace( "Reconnected to Database Server FAILURE!\n") ;
			return ;
		}
		bms_trace("Reconnected to Database Server OK!\n") ;
	}

	return ;
}

void warning_handler()
{
	if (sqlca.sqlwarn[1] == 'W')
	{
		bms_trace("Data truncated.\n");
	}

	if (sqlca.sqlwarn[3] == 'W')
	{
		bms_trace("Insufficient host variables to store results.\n");
	}	

	return;
}

void notfound_handler()
{
	bms_trace("No data found for the query.");
	return;
}

int  DB_connectDB(char *uid, char *pwd, char *svc)
{
	
           /*
           ** SQL STATEMENT: 4
           ** EXEC SQL BEGIN DECLARE SECTION ;
           */
# line 96 "dbfunc.cp"
 
	char username[64] ;
	char password[64] ;
	char svcname[64];
	
           /*
           ** SQL STATEMENT: 5
           ** EXEC SQL END DECLARE SECTION ;
           */
# line 100 "dbfunc.cp"

           /*
           ** Generated code ends here.
           */
# line 100 "dbfunc.cp"


	
           /*
           ** SQL STATEMENT: 6
           ** EXEC SQL WHENEVER SQLERROR CALL error_handler() ;
           */
# line 102 "dbfunc.cp"

	
           /*
           ** SQL STATEMENT: 7
           ** EXEC SQL WHENEVER SQLWARNING CALL warning_handler() ;
           */
# line 103 "dbfunc.cp"

	
           /*
           ** SQL STATEMENT: 8
           ** EXEC SQL WHENEVER NOT FOUND CALL notfound_handler() ;
           */
# line 104 "dbfunc.cp"


	memset( username, '\0', sizeof( username)) ;
	memset( username, '\0', sizeof( username)) ;
	memset( password, '\0', sizeof( password)) ;

	strcpy(svcname, svc);
	strcpy(username, uid) ;
	strcpy(password, pwd) ;

	
           /*
           ** SQL STATEMENT: 9
           ** EXEC SQL CONNECT :username IDENTIFIED BY :password USING :svcname;
           */
# line 114 "dbfunc.cp"
# line 114 "dbfunc.cp"
           {
# line 114 "dbfunc.cp"
                _SQL_CT_HANDLES * _sql;
# line 114 "dbfunc.cp"
               _sqlinitctx(&_sql, CS_VERSION_125, CS_TRUE, &sqlca, (long 
# line 114 "dbfunc.cp"
                   *)NULL, (CS_CHAR *)NULL);
# line 114 "dbfunc.cp"
               if (_sql != (_SQL_CT_HANDLES *) NULL)
# line 114 "dbfunc.cp"
               {
# line 114 "dbfunc.cp"
                   _sql->stmtData.persistent = CS_FALSE;
# line 114 "dbfunc.cp"
                   _sql->stmttype = SQL_NONANSI_CONNECT;
# line 114 "dbfunc.cp"
                   _sql->connName.lnlen = CS_NULLTERM;
# line 114 "dbfunc.cp"
                   strcpy(_sql->connName.last_name, svcname);
# line 114 "dbfunc.cp"
                   if ((_sql->retcode = _sqlprolog(_sql)) == CS_SUCCEED)
# line 114 "dbfunc.cp"
                   {
# line 114 "dbfunc.cp"
                       if (_sql->doDecl == CS_TRUE)
# line 114 "dbfunc.cp"
                       {
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_con_props(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_USERNAME, username, CS_NULLTERM, NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_con_props(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_PASSWORD, password, CS_NULLTERM, NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = _sqlctdiag(_sql, CS_CLEAR, 
# line 114 "dbfunc.cp"
                                   CS_UNUSED);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_capability(_sql->conn.connection, CS_SET,
# line 114 "dbfunc.cp"
                                    CS_CAP_RESPONSE, CS_RES_NOSTRIPBLANKS, 
# line 114 "dbfunc.cp"
                                   &_sql->cstrue);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_con_props(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_EXTRA_INF, &_sql->cstrue, CS_UNUSED, 
# line 114 "dbfunc.cp"
                                   NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_con_props(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_ANSI_BINDS, &_sql->cstrue, CS_UNUSED, 
# line 114 "dbfunc.cp"
                                   NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_connect(_sql->conn.connection, svcname, 
# line 114 "dbfunc.cp"
                                   CS_NULLTERM);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_con_props(_sql->conn.connection, CS_GET, 
# line 114 "dbfunc.cp"
                                   CS_TDS_VERSION, &_sql->temp_int, CS_UNUSED, 
# line 114 "dbfunc.cp"
                                   &_sql->outlen);
# line 114 "dbfunc.cp"
                               if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                               {
# line 114 "dbfunc.cp"
                                   if (_sql->temp_int < CS_TDS_50)
# line 114 "dbfunc.cp"
                                   {
# line 114 "dbfunc.cp"
                                       _sqlsetintrerr(_sql, (CS_INT) 
# line 114 "dbfunc.cp"
                                           _SQL_INTRERR_25013);
# line 114 "dbfunc.cp"
                                   }
# line 114 "dbfunc.cp"
                                   
# line 114 "dbfunc.cp"
                               }
# line 114 "dbfunc.cp"
                               
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_ANSINULL, &_sql->cstrue, CS_UNUSED, 
# line 114 "dbfunc.cp"
                                   NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_ANSIPERM, &_sql->cstrue, CS_UNUSED, 
# line 114 "dbfunc.cp"
                                   NULL);
# line 114 "dbfunc.cp"
                               _sql->retcode = CS_SUCCEED;
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_STR_RTRUNC, &_sql->cstrue, CS_UNUSED,
# line 114 "dbfunc.cp"
                                    NULL);
# line 114 "dbfunc.cp"
                               _sql->retcode = CS_SUCCEED;
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_ARITHABORT, &_sql->csfalse, 
# line 114 "dbfunc.cp"
                                   CS_UNUSED, NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_TRUNCIGNORE, &_sql->cstrue, 
# line 114 "dbfunc.cp"
                                   CS_UNUSED, NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_ARITHIGNORE, &_sql->csfalse, 
# line 114 "dbfunc.cp"
                                   CS_UNUSED, NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_ISOLATION, &_sql->Level3, CS_UNUSED, 
# line 114 "dbfunc.cp"
                                   NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_CHAINXACTS, &_sql->cstrue, CS_UNUSED,
# line 114 "dbfunc.cp"
                                    NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_CURCLOSEONXACT, &_sql->cstrue, 
# line 114 "dbfunc.cp"
                                   CS_UNUSED, NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"
                           if (_sql->retcode == CS_SUCCEED)
# line 114 "dbfunc.cp"
                           {
# line 114 "dbfunc.cp"
                               _sql->retcode = 
# line 114 "dbfunc.cp"
                                   ct_options(_sql->conn.connection, CS_SET, 
# line 114 "dbfunc.cp"
                                   CS_OPT_QUOTED_IDENT, &_sql->cstrue, 
# line 114 "dbfunc.cp"
                                   CS_UNUSED, NULL);
# line 114 "dbfunc.cp"
                           }
# line 114 "dbfunc.cp"
                           
# line 114 "dbfunc.cp"