Liren Large Software Subsidy 5/05.iso/a/a063/9.img/SAMPLE/DBLIB/EXAMPLE2.C

C/C++ Source or Header | 1991-01-02 | 5.3 KB | 214 lines

/*
**    example2.c
**
** This example opens a data file, inserts data from the file
** into a newly created table containing several of the
** SQL Server datatypes, and binds and prints the results.
*/

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

#define BUFLEN      2048
#define HEXLEN      510
#define PLEN        25

/* Function Prototypes */
int             err_handler(DBPROCESS *, int, int, int, char *, char *);
int             msg_handler(DBPROCESS *, DBINT, int, int, char *, char *,
                                        char *, DBUSMALLINT);
int                  main();

main()
{

    LOGINREC         *login;
    DBPROCESS        *dbproc;
    RETCODE          return_code;

    DBTINYINT        age;
    DBSMALLINT       userid;
    DBINT            royalty;
    DBCHAR           name[PLEN+1];
    DBBINARY         title_id[PLEN+1];
    DBBIT            us_citizen;
    DBFLT8           account;
    DBCHAR           title[PLEN+1];     /* string    */
    DBCHAR           manager[PLEN+1];   /* ntbstring */
    DBCHAR           id_buffer[HEXLEN+1];

    char             cmdbuf[BUFLEN];
    FILE             *infile;

    /* 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();
    DBSETLPWD(login, "server_password");
    DBSETLAPP(login, "example2");

    dbproc = dbopen(login, NULL);

    printf("Creating the 'test' database.\n");

    dbcmd(dbproc,"create database test ");

    dbsqlexec(dbproc);

    dbuse(dbproc,"test");

    printf("Creating the 'alltypes' table.\n");

    /* Create a table that contains several SQL Server datatypes. */
    dbcmd(dbproc,"create table alltypes ");
    dbcmd(dbproc,"(age tinyint,");
    dbcmd(dbproc,"userid smallint,");
    dbcmd(dbproc,"royalty int,");
    dbcmd(dbproc,"name char(25),");
    dbcmd(dbproc,"title_id varbinary(20),");
    dbcmd(dbproc,"us_citizen bit,");
    dbcmd(dbproc,"account float,");
    dbcmd(dbproc,"title varchar(20),");
    dbcmd(dbproc,"manager char(25))");


    dbsqlexec(dbproc);

    /* Insert rows of data into the newly created table "alltypes".
     * We will read in the contents of the file and form an
     * INSERT statement.
     */

    if ((infile=fopen("datafile","r")) == NULL)
    {
        printf("Unable to open file 'datafile'.\n");
        exit(STDEXIT);
    }

    printf("Inserting rows into the 'alltypes' table.\n");

    while ((fgets(cmdbuf,BUFLEN,infile)) != NULL)
    {
        dbfcmd(dbproc,"insert into alltypes \n");
        dbfcmd(dbproc,"values(%s) \n",cmdbuf);
    }

    dbsqlexec(dbproc);

    /* Process the results of each of the INSERT statements. */

    while ((return_code = dbresults(dbproc)) != NO_MORE_RESULTS)
    {
        if (return_code == FAIL)
            printf("One of the insert statements FAILed.\n");
    }

    printf("Selecting rows from the 'alltypes' table:\n");

    dbcmd(dbproc,"select * from alltypes");
    dbsqlexec(dbproc);

    while ((return_code = dbresults(dbproc)) != NO_MORE_RESULTS)
    {
        if (return_code == SUCCEED)
        {
            dbbind(dbproc, 1, TINYBIND, (DBINT)0, (BYTE *)&age);
            dbbind(dbproc, 2, SMALLBIND, (DBINT)0, (BYTE *)&userid);
            dbbind(dbproc, 3, INTBIND, (DBINT)0, (BYTE *)&royalty);
            dbbind(dbproc, 4, CHARBIND, (DBINT)0, name);
            dbbind(dbproc, 5, BINARYBIND, (DBINT)0, title_id);
            dbbind(dbproc, 6, BITBIND, (DBINT)0, (BYTE *)&us_citizen);
            dbbind(dbproc, 7, FLT8BIND, (DBINT)0, (BYTE *)&account);
            dbbind(dbproc, 8, STRINGBIND, (DBINT)0, title);
            dbbind(dbproc, 9, NTBSTRINGBIND, (DBINT)0, manager);

            /*
            ** Initialize null terminator in "name" array,
            ** since CHARBIND does not add one.
            */
            name[PLEN] = '\0';

            while (dbnextrow(dbproc) != NO_MORE_ROWS)
            {
                dbconvert
                    (dbproc, SYBBINARY, title_id,
                     dbdatlen(dbproc, 5), SYBCHAR, id_buffer, (DBINT)-1);
                printf
                    ("%d  %d  %ld  %s  0x%s\n",
                     age, userid, royalty, name, id_buffer);
                printf
                    ("%d  %8.2f  %s  %s\n",
                     us_citizen, account, title, manager);
            }
        }
    }

    dbexit();
    exit(STDEXIT);

}

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

        if (oserr != DBNOERR)
            printf("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;

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

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

    printf("\n\t%s\n", msgtext);

    return(0);
}