example8.c

在SCO UNIX5.05

/*
** Confidential property of Sybase, Inc.
** (c) Copyright Sybase, Inc. 1992 to ???
** All rights reserved.
*/

/*
** %M%:      %I%      %G%      %U%
**  
**  
**  
*/
#if USE_SCCSID
static char Sccsid[] = {"%Z% %M% %I% %G%"};
#endif /* USE_SCCSID */

/*
**	example8.c
**
** This example illustrates how to use remote procedure calls
** and how to process return parameter values from stored
** procedures.  
**
** The example uses the following stored procedure, 
** named "rpctest", which it assumes is located in the 
** user's default database.  Before running this example, 
** you must create "rpctest" in your default database.
**
**     create procedure rpctest
**         (@param1 int out,
**          @param2 int out,
**          @param3 int out,
**          @param4 int)
**     as
**     begin
**         select "rpctest is running."
**         select @param1 = 11
**         select @param2 = 22
**         select @param3 = 33
**         select @param1
**
**         return 123
**     end
**
*/


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

#include <sybfront.h>
#include <sybdb.h>
#include "sybdbex.h"

#define FMTSTR    "%-8.8s %-8.8s %-8.8s %-8.8s\n"
#define FMTSTR1    "%-8.8s %-8.8s %8.8ld %8.8ld\n"

/* Forward reference
*/
void doexit PROTOTYPE((char *));

main()
{
	LOGINREC         *login;
	DBPROCESS        *dbproc;

	int              i;
	int              numrets;
	DBINT            param1 = 1;
	DBINT            param2 = 2;
	DBINT            param3 = 3;
	DBINT            param4 = 4;
	RETCODE          return_code;

	printf("Demo of the use of remote procedure calls\n\n");
	fflush(stdout);

	/* Initialize DB-Library. */
	if (dbinit() == FAIL)
		exit(ERREXIT);

	/* Install the user-supplied error-handling and message-handling
	 * routines. They are defined at the bottom of this source file.
	 */
	dberrhandle(err_handler);
	dbmsghandle(msg_handler);
	
	/* Allocate and initialize the LOGINREC structure to be used
	 * to open a connection to SQL Server.
	 */

	login = dblogin( );
	DBSETLUSER(login, USER);
	DBSETLPWD(login, PASSWORD);
	DBSETLAPP(login, "rpcexample");
	
	dbproc = dbopen(login, (char *)NULL);

	/* Make the rpc. */
	if (dbrpcinit(dbproc, "rpctest", (DBSMALLINT)0) == FAIL)
		doexit("dbrpcinit failed.\n");

	if (dbrpcparam
	       (dbproc, "@param1", (BYTE)DBRPCRETURN, SYBINT4, -1, -1, (BYTE *)&param1)
	   == FAIL)
		doexit("dbrpcparam 1 failed.\n");

	if (dbrpcparam(dbproc, "@param2", (BYTE)0, SYBINT4, -1, -1, (BYTE *)&param2)
	   == FAIL)
		doexit("dbrpcparam 2 failed.\n");

	if (dbrpcparam
	       (dbproc, "@param3", (BYTE)DBRPCRETURN, SYBINT4, -1, -1, (BYTE *)&param3)	
	   == FAIL)
		doexit("dbrpcparam 3 failed.\n");

	if (dbrpcparam(dbproc, "@param4", (BYTE)0, SYBINT4, -1, -1, (BYTE *)&param4)
	   == FAIL)
		doexit("dbrpcparam 4 failed.\n");

	if (dbrpcsend(dbproc) == FAIL)
		doexit("dbrpcsend failed.\n");

	if (dbsqlok(dbproc) == FAIL)
		doexit("dbsqlok failed.\n");

	while ((return_code = dbresults(dbproc)) != NO_MORE_RESULTS)
	{
		if (return_code == FAIL)
			doexit("dbresults failed.\n");

		/* Print any rows that may have been returned. */
		dbprrow(dbproc);
	}

	/* Examine any return parameters that may have arrived. */

	numrets = dbnumrets(dbproc);
	printf("%d return values received.\n\n", numrets);

	if (numrets > 0)
	{
		printf
		 (FMTSTR, "Name", "Type", "Length", "Value");
		printf
			(FMTSTR,
			 "------------", "------------",
			 "------------", "------------");
	}

	for (i = 1; i <= numrets; i++)
	{
		printf
			(FMTSTR1, dbretname(dbproc, i),
			 dbprtype(dbrettype(dbproc, i)), dbretlen(dbproc, i),
			 *((DBINT *)(dbretdata(dbproc, i))));
	}

	if (dbhasretstat(dbproc))
		printf("Return status = %ld\n", dbretstatus(dbproc));
	else
		printf("No return status for this command.\n");

	dbexit();
}


void doexit(s1)
char *s1;
{
	printf(s1);
    dbexit();            /* always call dbexit before returning to OS */
    exit(ERREXIT);
}


int err_handler(dbproc, severity, dberr, oserr, dberrstr, oserrstr)
DBPROCESS    *dbproc;
int          severity;
int          dberr;
int          oserr;
char         *dberrstr;
char         *oserrstr;
{
    if ((dbproc == (DBPROCESS *)NULL) || (DBDEAD(dbproc)))
        return(INT_EXIT);
    else 
    {
        fprintf (ERR_CH, "DB-Library error:\n\t%s\n", dberrstr);

        if (oserr != DBNOERR)
            fprintf (ERR_CH, "Operating-system error:\n\t%s\n", oserrstr);

        return(INT_CANCEL);
    }
}

int msg_handler(dbproc, msgno, msgstate, severity, msgtext, 
                srvname, procname, line)

DBPROCESS       *dbproc;
DBINT           msgno;
int             msgstate;
int             severity;
char            *msgtext;
char            *srvname;
char            *procname;
DBUSMALLINT     line;

{
	fprintf (ERR_CH, "Msg %ld, Level %d, State %d\n", 
	        msgno, severity, msgstate);

	if (strlen(srvname) > 0)
		fprintf (ERR_CH, "Server '%s', ", srvname);
	if (strlen(procname) > 0)
		fprintf (ERR_CH, "Procedure '%s', ", procname);
	if (line > 0)
		fprintf (ERR_CH, "Line %d", line);

	fprintf (ERR_CH, "\n\t%s\n", msgtext);

	return(0);
}