软件开发培训班 >> 编程开发 >> DB2


一个将SQL语句嵌入到Java应用程序中的实例

　　本文标签：SQL语句 嵌入式SQL Java

　　我们在将SQL语句嵌入应用程序时，必须按以下的两个步骤预编译应用程序并将其与数据库联编，步骤如下：

　　1.创建源文件，以包含带嵌入式SQL语句的程序  。

　　格式: # SQL{ SQL语句 }   。

　　2.连接数据库，然后预编译每个源文件  。

　　语法: SQLJ 源文件名  。

　　实例如下：

　　

  1. import java.sql.*;  
  2.  
  3. import sqlj.runtime.*;  
  4.  
  5. import sqlj.runtime.ref.*;  
  6.  
  7. #sql iterator App_Cursor1 (String empno, String firstnme) ;  
  8.  
  9. #sql iterator App_Cursor2 (String) ;  
  10.  
  11. class App  
  12.  
  13. {  
  14.  
  15. static  
  16.  
  17. {  
  18.  
  19. try  
  20.  
  21. {  
  22.  
  23. Class.forName("sun.jdbc.odbc.JdbcOdbcDriver").newInstance();  
  24.  
  25. }  
  26.  
  27. catch (Exception e)  
  28.  
  29. {  
  30.  
  31. e.printStackTrace();  
  32.  
  33. }  
  34.  
  35. }  
  36.  
  37. public static void main(String argv[])  
  38.  
  39. {  
  40.  
  41. try  
  42.  
  43. {  
  44.  
  45. App_Cursor1 cursor1;  
  46.  
  47. App_Cursor1 cursor2;  
  48.  
  49. String str1 = null;  
  50.  
  51. String str2 = null;  
  52.  
  53. int count1;  
  54.  
  55. Connection con = null;  
  56.  
  57. String url = "jdbc:odbc:tese2";  
  58.  
  59. DefaultContext ctx = DefaultContext.getDefaultContext();  
  60.  
  61. if (ctx == null) {  
  62.  
  63. try {  
  64.  
  65. if (argv.length == 0) {  
  66.  
  67. String userid ="tdl";  
  68.  
  69. String passwd ="user";  
  70.  
  71. con = DriverManager.getConnection(url, userid, passwd);  
  72.  
  73. }  
  74.  
  75. else if (argv.length == 2) {  
  76.  
  77. // connect with default id/password  
  78.  
  79. con = DriverManager.getConnection(url);  
  80.  
  81. }  
  82.  
  83. else {  
  84.  
  85. System.out.println("Usage: java App [username password]");  
  86.  
  87. System.exit(0);  
  88.  
  89. }  
  90.  
  91. con.setAutoCommit(false);  
  92.  
  93. ctx = new DefaultContext(con);  
  94.  
  95. }  
  96.  
  97. catch (SQLException e) {  
  98.  
  99. System.out.println("Error: could not get a default context");  
  100.  
  101. System.err.println(e) ;  
  102.  
  103. System.exit(1);  
  104.  
  105. }  
  106.  
  107. DefaultContext.setDefaultContext(ctx);  
  108.  
  109. }  
  110.  
  111. #sql cursor1 = { SELECT empno, firstnme from db2admin.employee };  
  112.  
  113.  
  114. System.out.println("Received results:");  
  115.  
  116. while (cursor1.next()) {  
  117.  
  118. str1 = cursor1.empno();  
  119.  
  120. str2 = cursor1.firstnme();  
  121.  
  122. System.out.print (" empno= " + str1);  
  123.  
  124. System.out.print (" firstname= " + str2);  
  125.  
  126. System.out.print ("");  
  127.  
  128. }  
  129.  
  130. cursor1.close();  
  131.  
  132. #sql cursor2 = { SELECT firstnme from db2admin.employee where empno = :str1 };  
  133.  
  134. System.out.println("Received results:");  
  135.  
  136. while (true) {  
  137.  
  138. #sql { FETCH :cursor2 INTO :str2 };  
  139.  
  140. if (cursor2.endFetch()) break;  
  141.  
  142. System.out.print (" empno= " + str1);  
  143.  
  144. System.out.print (" firstname= " + str2);  
  145.  
  146. System.out.print ("");  
  147.  
  148. }  
  149.  
  150. cursor2.close();  
  151.  
  152. // rollback the update  
  153.  
  154. System.out.println("Rollback the update...");  
  155.  
  156. #sql { ROLLBACK work };  
  157.  
  158. System.out.println("Rollback done.");  
  159.  
  160. }  
  161.  
  162. catch( Exception e )  
  163.  
  164. {  
  165.  
  166. e.printStackTrace();  
  167.  
  168. }  
  169.  
  170. }  
  171.  
  172. } 

　　

　　注：本程序采用JDBCODBC桥的方式访问数据库，必须配置ODBC数据源  。

　　关于嵌入式SQL（SQLJ)的知识就介绍到这里了，希望本次的介绍能够给您带来一些收获！