C语言操作SQL

q968

　　

　　C语言操作SQL
　　


/* ** 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
**
*/

 　　


#if defined(DBNTWIN32)
#include <windows.h>;
#endif
#include <stdio.h>;
#include <stdlib.h>;
#include <sqlfront.h>;
#include <sqldb.h>;
#define FMTSTR "%-8.8s %-8.8s %-8.8s %-8.8s\n"
#define FMTSTR1 "%-8.8s %-8.8s %8.8ld %8.8ld\n"
/* Forward declarations of the error handler and message handler routines. */
int err_handler(DBPROCESS*, int, int, int, char*, char*);
int msg_handler(DBPROCESS*, DBINT, int, int, char*, char*, char*, DBUSMALLINT);
void main()
{
LOGINREC       *login;
DBPROCESS        *dbproc;
int              i;
int              numrets;
DBINT          param1 = 1;
DBINT          param2 = 2;
DBINT          param3 = 3;
DBINT          param4 = 4;
RETCODE       return_code;
/* Initialize private DB Library structures. */
dbinit();

/* Install the user-supplied error-handling and message-handling
* routines. They are defined at the bottom of this source file.
*/
dbmsghandle((DBMSGHANDLE_PROC)msg_handler);
dberrhandle((DBERRHANDLE_PROC)err_handler);
/* Allocate and initialize the LOGINREC structure to be used
* to open a connection to SQL Server.
*/
login = dblogin( );
DBSETLUSER(login, "user");
DBSETLPWD(login, "my_passwd");
DBSETLAPP(login, "rpcexample");
DBSETLVERSION(login, DBVER60);
dbproc = dbopen(login, (char *)"my_server");
/* Make the rpc. */
if (dbrpcinit(dbproc, "rpctest", (DBSMALLINT)0) == FAIL)
{
printf("dbrpcinit failed.\n");
dbexit();
exit(ERREXIT);
}
if (dbrpcparam(dbproc, "@param1", (BYTE)DBRPCRETURN, SQLINT4,
-1, -1, (BYTE *)&param1)
== FAIL)
{
printf("dbrpcparam failed.\n");
dbexit();
exit(ERREXIT);
}
if (dbrpcparam(dbproc, "@param2", (BYTE)DBRPCRETURN, SQLINT4,
-1, -1, (BYTE *)&param2)
== FAIL)
{
printf("dbrpcparam failed.\n");
dbexit();
exit(ERREXIT);
}
if (dbrpcparam(dbproc, "@param3", (BYTE)DBRPCRETURN, SQLINT4,
-1, -1, (BYTE *)&param3)
== FAIL)
{
printf("dbrpcparam failed.\n");
dbexit();
exit(ERREXIT);
}
if (dbrpcparam(dbproc, "@param4", (BYTE)NULL, SQLINT4,
-1, -1, (BYTE *)&param4)
== FAIL)
{
printf("dbrpcparam failed.\n");
dbexit();
exit(ERREXIT);
}
if (dbrpcsend(dbproc) == FAIL)
{
printf("dbrpcsend failed.\n");
dbexit();
exit(ERREXIT);
}
if (dbsqlok(dbproc) == FAIL)
{
printf("dbsqlok failed.\n");
dbexit();
exit(ERREXIT);
}
while ((return_code = dbresults(dbproc)) != NO_MORE_RESULTS)
{
if (return_code == FAIL)
{
printf("dbresults failed.\n");
dbexit();
exit(ERREXIT);
}
/* 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();
}
int err_handler(DBPROCESS *dbproc, int severity, int dberr, int oserr, char *dberrstr, char *oserrstr)
{
if (dberrstr != NULL) printf("DB-Library error:\n\t%s\n", dberrstr);
if (oserr != DBNOERR)
printf("Operating-system error:\n\t%s\n", oserrstr);
if ((dbproc == NULL) || (DBDEAD(dbproc)))
return(INT_EXIT);
else
{
return(INT_CANCEL);
}
}
int msg_handler(DBPROCESS *dbproc, DBINT msgno,int msgstate, int severity, char *msgtext, char *srvname, char *procname, DBUSMALLINT line)
{
printf ("Msg %ld, Level %d, State %d\n",
msgno, severity, msgstate);
if (srvname !=   NULL)
printf ("Server '%s', ", srvname);
if (procname !=   NULL)
printf ("Procedure '%s', ", procname);
if (line !=   0)
printf ("Line %d", line);
printf("\n\t%s\n", msgtext);
return(0);
}