EXAMPLE6.C
上传用户:bangxh
上传日期:2007-01-31
资源大小:42235k
文件大小:5k
源码类别:

Windows编程

开发平台:

Visual C++

  1. /* example6.c */
  2. /*
  3. ** This example illustrates opening a data file, inserting data
  4. ** from the file into a newly created table containing several
  5. ** SQL Server datatypes, and updating the table using browse mode
  6. ** techniques.
  7. */
  8. #if defined(DBNTWIN32)
  9. #include <windows.h>
  10. #endif
  11. #include <stdio.h>
  12. #include <sqlfront.h>
  13. #include <sqldb.h>
  14. #define BUFLEN 2048
  15. /* Forward declarations of the error-handling and message-handing
  16. functions. */
  17. int err_handler(DBPROCESS*, int, int, int, char*, char*);
  18. int msg_handler(DBPROCESS*, DBINT, int, int, char*);
  19. main()
  20. {
  21. LOGINREC *login;
  22. DBPROCESS *q_dbproc; /* This DBPROCESS is used to
  23. * query the database.
  24. */
  25. DBPROCESS *u_dbproc; /* This DBPROCESS is used to
  26. * simultaneously update the database.
  27. */
  28. const char  *qualptr; /* This points to the WHERE clause
  29. * appropriate for updating q_dbproc's
  30. * current data row.
  31. */
  32. RETCODE return_code;
  33. DBTINYINT age;
  34. static char cmdbuf[BUFLEN];
  35. FILE *infile;
  36.         dbinit(); /* initialize dblib */
  37. /* Install the user-supplied error-handling and message-handling
  38. * functions. They are defined at the bottom of this source file.
  39. */
  40. dbmsghandle((DBMSGHANDLE_PROC)msg_handler);
  41. dberrhandle((DBERRHANDLE_PROC)err_handler);
  42. /* Allocate and initialize the LOGINREC structure to be used
  43. * to open a connection to SQL Server.
  44. */
  45. login = dblogin();
  46. DBSETLUSER(login, "user");
  47. DBSETLPWD(login, "my_passwd");
  48. DBSETLAPP(login, "example6");
  49. DBSETLVERSION(login, DBVER60);
  50. q_dbproc = dbopen(login, "my_server");
  51. u_dbproc = dbopen(login, "my_server");
  52. printf("Creating the 'alltypes' table.n");
  53. /* Create a table that contains several SQL Server datatypes. */
  54. dbcmd(q_dbproc,"if exists(select name from sysobjects where name='alltypes') drop table alltypes ");
  55. dbcmd(q_dbproc,"create table alltypes ");
  56. dbcmd(q_dbproc,"(age tinyint,");
  57. dbcmd(q_dbproc,"userid smallint,");
  58. dbcmd(q_dbproc,"royalty int,");
  59. dbcmd(q_dbproc,"name char(25),");
  60. dbcmd(q_dbproc,"title_id varbinary(20),");
  61. dbcmd(q_dbproc,"us_citizen bit,");
  62. dbcmd(q_dbproc,"account float,");
  63. dbcmd(q_dbproc,"title varchar(20),");
  64. dbcmd(q_dbproc,"manager char(25),");
  65. dbcmd(q_dbproc,"sales decimal(10,2),");
  66. dbcmd(q_dbproc,"timestamp)");
  67. dbcmd(q_dbproc, "create unique index index1 on alltypes(userid)");
  68. dbsqlexec(q_dbproc);
  69. while (dbresults(q_dbproc) != NO_MORE_RESULTS)
  70. continue;
  71. /* Insert rows of data into the newly created table "alltypes".
  72. * We will read in the contents of the file and form an
  73. * INSERT statement.
  74. */
  75. if ((infile=fopen("datafile","r")) == NULL)
  76. {
  77. printf("Unable to open file 'datafile'.n");
  78. return(STDEXIT);
  79. }
  80. printf("Inserting rows into the 'alltypes' table...n");
  81. while ((fgets(cmdbuf,BUFLEN,infile)) != NULL)
  82. {
  83. dbfcmd(q_dbproc,"insert into alltypes n");
  84. dbfcmd(q_dbproc,"values(%s, null) n",cmdbuf);
  85. }
  86. dbsqlexec(q_dbproc);
  87. /* Process the results of each of the INSERT statements. */
  88. while ((return_code = dbresults(q_dbproc)) != NO_MORE_RESULTS)
  89. {
  90. if (return_code == FAIL)
  91. printf("One of the insert statements failed.n");
  92. }
  93. /* Using DB-LIBRARY's browse mode facilities, we'll increment
  94. * the age of every person in the table.
  95. */
  96. printf("Updating rows in the 'alltypes' table...n");
  97. dbcmd(q_dbproc,"select * from alltypes for browse");
  98. dbsqlexec(q_dbproc);
  99. while ((return_code = dbresults(q_dbproc)) != NO_MORE_RESULTS)
  100. {
  101. if (return_code == SUCCEED)
  102. {
  103. while (dbnextrow(q_dbproc) != NO_MORE_ROWS)
  104. {
  105. age = *((DBTINYINT *)(dbdata(q_dbproc, 1)));
  106. qualptr = dbqual(q_dbproc, -1, "alltypes");
  107. dbcmd(u_dbproc, "update alltypes");
  108. dbfcmd
  109. (u_dbproc, " set age = %d %s", age+1, qualptr);
  110. dbsqlexec(u_dbproc);
  111. dbresults(u_dbproc);
  112. dbfreequal(qualptr);
  113. }
  114. }
  115. }
  116. /* Now, we'll look at the updated contents of the table to
  117. * verify that the ages were properly incremented.
  118. */
  119. printf("Selecting rows from the 'alltypes' table:n");
  120. dbcmd(q_dbproc, "select * from alltypes");
  121. dbsqlexec(q_dbproc);
  122. dbresults(q_dbproc);
  123. dbprrow(q_dbproc);
  124. printf("Dropping 'alltypes' table:n");
  125. dbcmd(q_dbproc, "drop table alltypes");
  126. dbsqlexec(q_dbproc);
  127. dbresults(q_dbproc);
  128. dbexit();
  129. return(STDEXIT);
  130. }
  131. int err_handler(dbproc, severity, dberr, oserr, dberrstr, oserrstr)
  132. DBPROCESS *dbproc;
  133. int severity;
  134. int dberr;
  135. int oserr;
  136. char *dberrstr;
  137. char *oserrstr;
  138. {
  139.     printf("DB-LIBRARY error:nt%sn", dberrstr);
  140. if (oserr != DBNOERR)
  141. printf("Operating-system error:nt%sn", oserrstr);
  142. if ((dbproc == NULL) || (DBDEAD(dbproc)))
  143. return(INT_EXIT);
  144. return(INT_CANCEL);
  145. }
  146. int msg_handler(dbproc, msgno, msgstate, severity, msgtext)
  147. DBPROCESS *dbproc;
  148. DBINT msgno;
  149. int msgstate;
  150. int severity;
  151. char *msgtext;
  152. {
  153. printf
  154. ("SQL Server message %ld, state %d, severity %d:nt%sn",
  155. msgno, msgstate, severity, msgtext);
  156. return(0);
  157. }