开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > OA系统 > 查看源码
WebPrint.java
资源名称：OA.rar　[点击查看]
上传用户：mingda
上传日期：2017-06-20
资源大小：27691k
文件大小：48k
源码类别：

OA系统

开发平台：

Java

WebPrint.java：源码内容
  1. /**
  2. 公司：北京方成科技发展有限公司
  3. 作者：梅勇
  4. 日期：2001.08.24
  5. */
  6. import java.io.*;
  7. import java.text.*;
  8. import java.util.*;
  9. import javax.servlet.*;
  10. import javax.servlet.http.*;
  11. import java.sql.*;
  12. //import explato.database.*;
  13. import sun.io.ByteToCharConverter; 
  17. import org.xml.sax.* ;
  18. import org.apache.xerces.dom.TextImpl;
  19. import org.w3c.dom.Attr;
  20. import org.w3c.dom.Document;
  21. import org.w3c.dom.NamedNodeMap;
  22. import org.w3c.dom.Node;
  23. import org.w3c.dom.NodeList;
  24. //import dom.DOMParserWrapper;
  25. //import dom.wrappers.DOMParser;
  26. //websphere+db2
  27. import COM.ibm.db2.jdbc.app.*;
  30. public class WebPrint extends HttpServlet {
  31. private int iPosition=1; //用于fc_select类查询中传位置参数
  32. //数据源名称,用户名,密码.用于报表查询时连接另外的数据源使用,用于fc_select1,fc_select2
  33. private String strDataSource=""; 
  34. private String strUserName="";
  35. private String strPassword="";
  37. private String strXml="";
  38. private ResultSet rs = null;
  39. private ResultSet rs1 = null;
  40. private ResultSet rs2 = null;
  41. private Connection con = null;
  42. //private ConnectionManager cm=null;
  43. private Document document=null;
  45.     public void doPost(HttpServletRequest req,
  46.                       HttpServletResponse res)
  47.         throws IOException, ServletException
  48.     {
  49. //设置演示版,
  50.      /*
  51.      long Time1=1026000000+23328000;
  52.      long curTime=0;
  53.      curTime=System.currentTimeMillis();
  54.      curTime=curTime/1000;
  55.     
  56.      //每天的时间为 86400
  57. if(curTime>Time1){ 
  58.      System.out.println("演示版已到期,系统将不正常!"); 
  59.      return ;
  60. }
  61. //------------------
  62. */
  63.         res.setContentType("text/html;charset=UTF-8");
  64.         PrintWriter out = res.getWriter();
  66. try {
  67. /*  
  68. 采用tomcat 用自做的连接池建立连接的方法
  69. // String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  70. // String sConnStr = "jdbc:odbc:ereport"; 
  71. // Class.forName(sDBDriver);
  72. // con = DriverManager.getConnection(sConnStr,"sa",""); 
  74.        ServletContext application = getServletContext();
  75. //ConnectionManager cm= (ConnectionManager)application.getAttribute("fcConPoolManager");
  76. cm=(ConnectionManager)application.getAttribute ( "fcConPoolManager" );
  77. //demo是配置文件中逻辑数据库的名字，同时也是连接池的名字
  80. con = cm.getConnection( "demo" );     //或者  con = cm.getConnection( "demo", 30000 );   //30000是不能马上取到连接时的等待时间(以毫秒计)
  81. */
  82. Class.forName("COM.ibm.db2.jdbc.app.DB2Driver");
  83. con=DriverManager.getConnection("jdbc:db2:sample","meiyong","");
  85. } catch (Exception e){
  86. //out.println("读表发生错误");
  87. }
  88. finally {
  89. //if( con != null ){
  90. // cm.freeConnection( "demo", con );
  91. //}
  92. }
  93. //-------------------------------------------------------
  94. //strKey为？后的值
  95. String strKey=new String(req.getQueryString());
  96. //计算前台SEND来的XML串 存入strXml中
  97. BufferedReader in = req.getReader();
  98. String line = null;
  99. strXml="";
  100. while ((line = in.readLine()) != null) {
  101.       strXml=strXml+line;
  102.     }        
  103. //parse XML串
  104.     try {
  105.         //DOMParserWrapper parser =
  106.         //(DOMParserWrapper)Class.forName("dom.wrappers.DOMParser").newInstance();
  107.         //document = parser.parseXml(strXml);
  108.     org.apache.xerces.parsers.DOMParser parser = 
  109.          new org.apache.xerces.parsers.DOMParser();    
  110.   InputSource myStr=new InputSource();
  111.      Reader myStr1=new StringReader(strXml);
  112.      myStr.setCharacterStream(myStr1);    
  113.         parser.parse(myStr);
  114.         document = parser.getDocument();        
  115. }
  116. catch (Exception e) {
  117.     }
  118. //--------------------------------------------------------
  119. //用一个CASE语句来处理各种方法
  121. if (strKey.equals("fillcombox")) out.print(fillcombox());
  122. //用于用SQL语句填充combox
  124. if (strKey.equals("checksql")) out.print(checksql());
  125. //用于检查SQL语句是否合法
  126. /*
  127. if (strKey.equals("fc_insertClob")) out.print(fc_insertClob());
  128. if (strKey.equals("fc_updateClob")) out.print(fc_updateClob());
  129. if (strKey.equals("fc_loadClob")) out.print(fc_loadClob());
  130. if (strKey.equals("fc_loadClob1")) out.print(fc_loadClob1());
  131. */
  132. if (strKey.equals("GetReportCell")) out.print(GetReportCell()); //跨表取数
  133. if (strKey.equals("fc_insert")) out.print(fc_insert());
  134. if (strKey.equals("fc_insert1")) out.print(fc_insert1()); //新增主子表
  135. if (strKey.equals("fc_update1")) out.print(fc_update1()); //新增主子表
  136. if (strKey.equals("fc_select")) out.print(fc_select());
  137. if (strKey.equals("fc_FieldToTable")) out.print(fc_FieldToTable());
  138. if (strKey.equals("GetDB")) out.print(GetDB());
  139. if (strKey.equals("fc_select1")) out.print(fc_select1()); //多个SQL同时查的查询
  140. if (strKey.equals("fc_select2")) out.print(fc_select2()); //明细和汇总都要的查询
  142. if (strKey.equals("twors")) out.print(twors());//两个结果集的测试
  143. if (strKey.equals("sqltoxml")) out.print(sqltoxml());//两个结果集的测试
  145. if (strKey.equals("dsnSetSession")) 
  146. {
  147. Node root = document.getChildNodes().item(0);
  148.         String strName=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  149.         String strValue="";
  150.         try {
  151.          //当此节点值为空时
  152.          strValue=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  153. }
  154. catch (Exception e) {   }
  156. HttpSession session = req.getSession(true);
  157. session.setAttribute(strName, strValue);
  158. out.print("");
  159. }
  160. if (strKey.equals("dsnGetSession")) 
  161. {
  162. Node root = document.getChildNodes().item(0);
  163.         String strName=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  164. HttpSession session = req.getSession(true);
  165. String strSR=session.getAttribute(strName).toString();;
  166. out.print(strSR);
  167. }
  169. if (strKey.equals("loadprint")) { 
  170. String strX="function%20detachPage%28%29%7B%20htmlToptmp%3DhtmlTop%3B%20htmlBottomtmp%3DhtmlBottom%3B%20var%20iStart%3D0%3B%20var%20iEnd%3D0%3B%20var%20lngEndLine%3Dt.rows.length-tabCauda%3B%20var%20colwidthXML%3DLoadUserData%28%22setcolwidth%22%2C%22ReportColWidth%22+ReportName%29%3B%20effectiveWidth%3DparseInt%28repWidth-tabLeft-tabRight%29%3B%20var%20oXML1%3Dnew%20ActiveXObject%28%22Microsoft.XMLDOM%22%29%3B%20oXML1.async%3D%22false%22%3B%20oXML1.loadXML%28%22%3Croot%3E%22%20+colwidthXML+%22%3C/root%3E%22%29%3B%20sumcol%3D0%3B%20var%20compressRate%3D1%3B%20if%28prnSet.compressWidth%3D%3D1%29%20%7B%20for%20%28var%20j%3D0%3Bj%3CMaxCols%3Bj++%29%7B%20if%20%28oXML1.documentElement.childNodes.item%28j%29.getAttribute%28%22colSelect%22%29%3D%3D%22block%22%29%7B%20sumcol%3Dsumcol+parseInt%28oXML1.documentElement.childNodes.item%28j%29.getAttribute%28%22colWidth%22%29%29%3B%20%7D%20%7D%20compressRate%3DeffectiveWidth/%28sumcol+MaxCols%29%3B%20if%28compressRate%3E%3D1%20%29%20%7B%20compressRate%3D1%3B%20%7D%20compressColWidth%28compressRate%29%3B%20%7D%20var%20hcompressRate%3D1%3B%20var%20t_outerHTMLbak%3Dt.outerHTML%3B%20if%28prnSet.compressHeight%3D%3D1%29%20%7B%20cur1%3D0%3B%20for%20%28var%20i%3DtabHead%3Bi%3ClngEndLine%3Bi++%29%20%7B%20cur1%3Dcur1+parseInt%28t.rows%28i%29.style.height%29%3B%20%7D%20hcompressRate%3D%28repHeight-tabBottom-tabTop-PageHeadHeight-PageCaudaHeight-heightTop-heightBottom%29/%28cur1+lngEndLine-tabHead%29%20%3B%20if%28hcompressRate%3E%3D1%20%29%20%7B%20hcompressRate%3D1%3B%20%7D%20compressRowHeight%28hcompressRate%2CtabHead%2ClngEndLine%29%3B%20%7D%20if%20%28prnSet.compressFont%21%3D1%29%20%7B%20var%20compressFont%3D0%3B%20if%28hcompressRate%3CcompressRate%29%20%7B%20compressFont%3DhcompressRate%3B%20%7D%20else%20%7B%20compressFont%3DcompressRate%3B%20%7D%20if%28compressFont%3C1%29%7B%20t.style.fontSize%3DparseFloat%28t.style.fontSize%29*compressFont%3B%20%7D%20%7D%20setAutoturnRow%28%29%3B%20cur1%3D0%3B%20for%20%28var%20i%3DtabHead%3Bi%3ClngEndLine%3Bi++%29%20%7B%20cur1%3Dcur1+parseInt%28t.rows%28i%29.style.height%29%3B%20if%20%28cur1%3E%3DrepHeight-tabBottom-tabTop-PageHeadHeight-PageCaudaHeight-heightTop-heightBottom%7C%7C%20i%3D%3DlngEndLine-1%29%7B%20if%20%28cur1%3D%3DrepHeight-tabBottom-tabTop-PageHeadHeight-PageCaudaHeight-heightTop-heightBottom%29%20%7B%20cur1%3D0%3B%20%7D%20else%20%7B%20cur1%3DparseInt%28t.rows%28i%29.style.height%29%3B%20%7D%20sumcol%3D0%3B%20var%20bFind%3Dfalse%3B%20iStart%3D0%3B%20iEnd%3D0%3B%20if%20%28i%3D%3DlngEndLine-1%29%7B%20perPageHTML%3DperPageHTML+t.rows%28i%29.outerHTML%20%3B%20%7D%20for%20%28var%20j%3D0%3Bj%3CMaxCols%3Bj++%29%7B%20if%20%28oXML1.documentElement.childNodes.item%28j%29.getAttribute%28%22colSelect%22%29%3D%3D%22block%22%29%7B%20sumcol%3Dsumcol+parseInt%28oXML1.documentElement.childNodes.item%28j%29.getAttribute%28%22colWidth%22%29%29*compressRate%3B%20%7D%20if%20%28sumcol%3E%3DeffectiveWidth%20%7C%7C%20j%3D%3DMaxCols-1%29%7B%20if%20%28sumcol%3C%3DeffectiveWidth%29%7B%20iEnd%3Dj%3B%20sumcol%3D0%3B%20%7D%20else%20%7B%20iEnd%3Dj-1%3B%20sumcol%3DparseInt%28oXML1.documentElement.childNodes.item%28j%29.getAttribute%28%22colWidth%22%29%29*compressRate%3B%20%7D%20var%20s1%3DHideCol%28strCol%2CiStart%2CiEnd%29%3B%20bFind%3Dtrue%3B%20PageDataAdd%28Pages%29%3B%20arrPage%5BPages%5D%3DhtmlTop+htmlBottom+tabstyle+s1%3B%20arrPage%5BPages%5D%3DarrPage%5BPages%5D+PageHeadHTML%3B%20arrPage%5BPages%5D%3DarrPage%5BPages%5D+perPageHTML+PageCaudaHTML+%22%3C/Table%3E%22%20+%22%3Cimg%20%3E%22%3B%20if%20%28i%3D%3DlngEndLine-1%29%7B%20if%28cur1%3ErepHeight-tabBottom-tabTop-PageHeadHeight-PageCaudaHeight-heightTop-heightBottom%29%7B%20PageDataAdd%28Pages+1%29%3B%20arrPage%5BPages+1%5D%3DhtmlTop+htmlBottom+tabstyle+s1%3B%20arrPage%5BPages+1%5D%3DarrPage%5BPages+1%5D+PageHeadHTML+PageCaudaHTML+%22%3C/Table%3E%22+%22%3Cimg%20%3E%22%3B%20biglabel.innerHTML%3Dbiglabel.innerHTML%20+%22%3Cdiv%20class%3DpreviewDiv%20%3E%u6B63%u5728%u8BA1%u7B97...%3C/DIV%3E%22%3B%20Pages%3DPages+1%3B%20%7D%20%7D%20biglabel.innerHTML%3Dbiglabel.innerHTML%20+%22%3Cdiv%20class%3DpreviewDiv%20%3E%u6B63%u5728%u8BA1%u7B97...%3C/DIV%3E%22%3B%20Pages%3DPages+1%3B%20if%20%28%28j%3D%3DMaxCols-1%20%29%20%26%26%20%28iEnd%3D%3Dj-1%29%20%29%7B%20var%20s1%3DHideCol%28strCol%2CMaxCols-1%2CMaxCols-1%29%3B%20bFind%3Dtrue%3B%20PageDataAdd%28Pages%29%3B%20arrPage%5BPages%5D%3DhtmlTop+htmlBottom+tabstyle+s1%3B%20arrPage%5BPages%5D%3DarrPage%5BPages%5D+PageHeadHTML%3B%20arrPage%5BPages%5D%3DarrPage%5BPages%5D+perPageHTML+PageCaudaHTML+%22%3C/Table%3E%22+%22%3Cimg%20%3E%22%3B%20if%20%28i%3D%3DlngEndLine-1%29%7B%20if%28cur1%3ErepHeight-tabBottom-tabTop-PageHeadHeight-PageCaudaHeight-heightTop-heightBottom%29%7B%20PageDataAdd%28Pages+1%29%3B%20arrPage%5BPages+1%5D%3DhtmlTop+htmlBottom+tabstyle+s1%20%3B%20arrPage%5BPages+1%5D%3DarrPage%5BPages+1%5D+PageHeadHTML+PageCaudaHTML+%22%3C/Table%3E%22+%22%3Cimg%20%3E%22%3B%20biglabel.innerHTML%3Dbiglabel.innerHTML%20+%22%3Cdiv%20class%3DpreviewDiv%20%3E%u6B63%u5728%u8BA1%u7B97...%3C/DIV%3E%22%3B%20Pages%3DPages+1%3B%20%7D%20%7D%20biglabel.innerHTML%3Dbiglabel.innerHTML%20+%22%3Cdiv%20class%3DpreviewDiv%20%3E%u6B63%u5728%u8BA1%u7B97...%3C/DIV%3E%22%3B%20Pages%3DPages+1%3B%20%7D%20iStart%3DiEnd+1%3B%20%7D%20%7D%20perPageHTML%3D%22%22%3B%20%7D%20perPageHTML%3DperPageHTML+t.rows%28i%29.outerHTML%20%3B%20%7D%20mdblRate%3D1%3B%20htmlTop%3D%22%22%3B%20htmlBottom%3D%22%22%3B%20t.outerHTML%3Dt_outerHTMLbak%3B%20t.style.display%3D%22none%22%3B%20for%28var%20i%3D0%3Bi%3CPages%3Bi++%29%7B%20arrPage%5Bi%5D%3Dfc_RepStr%28arrPage%5Bi%5D%2C%22%28P%29%22%2CPages+%22%22%29%3B%20%7D%20%7D%20";
  171. out.println(strX);
  172. }
  178. }
  181. /*
  182. //下面是自定义的方法
  183. //--------------------------------------
  184. private String fc_insertClob() {
  185. Node root = document.getChildNodes().item(0);
  186.     String strName=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  187.     String strTable=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  188.     String strTable1=root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  189. String sTmp = "";
  190. //System.out.println("1:"+strTable) ;
  191. //java.sql.Blob myBlob     = null;
  192.     java.sql.Clob myClob     = null;
  193.     java.sql.Clob myClob1     = null;
  194.   // set Oracle's Auto Commit feature to false. 
  195.   // This is necessary when manipulating Blobs and Clobs.
  196. // CallableStatement cstmt=null;
  197. try {
  198.   con.setAutoCommit(false);
  199.   Statement stmt = con.createStatement();
  200.       stmt.execute("insert into fccell values ('"+strName+"',EMPTY_CLOB(),EMPTY_CLOB(),null)");
  201.       // ============== Manipulating the Clob column ======================
  202.       // get a reference to the clob column
  203.       stmt.execute("select * from fccell where fstrtablename='"+strName+"'");
  204.       ResultSet crs = stmt.getResultSet();
  205.       while ( crs.next() ) {
  206.           myClob = crs.getClob("fstrtable");
  207.   //oracle用此行
  208.           java.io.OutputStream osss =((weblogic.jdbc.common.OracleClob) myClob).getAsciiOutputStream();
  210.           //java.io.OutputStream osss = myClob.getAsciiOutputStream();
  212.           byte[] bss = strTable.getBytes("ASCII");
  213.           osss.write(bss);
  214.           osss.flush();
  217.           myClob1 = crs.getClob("fstrtable1");
  218.           
  219.           java.io.OutputStream osss1 =((weblogic.jdbc.common.OracleClob) myClob1).getAsciiOutputStream();
  220.           //java.io.OutputStream osss1 = myClob1.getAsciiOutputStream();
  222.           byte[] bss1 = strTable1.getBytes("ASCII");
  223.           osss1.write(bss);
  224.           osss1.flush();
  226.       }
  227.       con.commit();
  228.       
  229.       // read back the clob
  230.       //System.out.println("nReading the clob back from the table and displaying:");
  232. }
  233. catch (Exception e){
  234. e.printStackTrace();
  235. sTmp=e.getMessage() ;
  236. }
  238. return sTmp ;
  240. }
  241. //--------------------------------------
  242. private String fc_updateClob() {
  243. Node root = document.getChildNodes().item(0);
  244.     String strName=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  245.     String strTable=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  246.     String strTable1=root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  247. String sTmp = "";
  248. //System.out.println("1:"+strSql) ;
  249. //java.sql.Blob myBlob     = null;
  250.     java.sql.Clob myClob     = null;
  251.     java.sql.Clob myClob1     = null;
  252.   // set Oracle's Auto Commit feature to false. 
  253.   // This is necessary when manipulating Blobs and Clobs.
  254. // CallableStatement cstmt=null;
  255. try {
  256. //con.setAutoCommit(false);
  257.   Statement stmt = con.createStatement();
  258.   //System.out.println("删除成功!"+strName);
  259.       stmt.executeUpdate("delete from fccell where fstrTableName='"+strName+"'");
  260. //con.commit();
  261.   //if (1==1){
  262.           //  stmt.close();
  263.           //  return "";
  264.            //}
  265.   
  266.   con.setAutoCommit(false);
  267.   stmt = con.createStatement();
  268.       //stmt.executeUpdate("delete from fccell where fstrTableName='"+strName+"'");
  269.   //System.out.println("删除成功!");
  270.           
  271.   stmt.execute("insert into fccell values ('"+strName+"',EMPTY_CLOB(),EMPTY_CLOB(),null)");
  272.   //stmt.execute("update fccell set fstrtablename='"+strName+"',fstrtable=EMPTY_CLOB(),fstrtable1=EMPTY_CLOB() where fstrtableName='"+strName+"'");
  273.       // ============== Manipulating the Clob column ======================
  274.       // get a reference to the clob column
  275.       stmt.execute("select * from fccell where fstrtablename='"+strName+"'");
  276.       ResultSet crs = stmt.getResultSet();
  277.       while ( crs.next() ) {
  279.           myClob = crs.getClob("fstrtable");
  280.   //oracle时用此行
  281.           java.io.OutputStream osss =((weblogic.jdbc.common.OracleClob) myClob).getAsciiOutputStream();
  283.           //java.io.OutputStream osss = myClob.getAsciiOutputStream();
  285.           byte[] bss = strTable.getBytes("ASCII");
  286.           osss.write(bss);
  287.           osss.flush();
  290.           myClob1 = crs.getClob("fstrtable1");
  291.           
  292.           java.io.OutputStream osss1 =((weblogic.jdbc.common.OracleClob) myClob1).getAsciiOutputStream();
  294.           //java.io.OutputStream osss1 = myClob1.getAsciiOutputStream();
  296.           byte[] bss1 = strTable1.getBytes("ASCII");
  297.           osss1.write(bss1);
  298.           osss1.flush();
  300.       }
  301.       con.commit();
  302.       
  303.       // read back the clob
  304.       //System.out.println("nReading the clob back from the table and displaying:");
  306. }
  307. catch (Exception e){
  308. e.printStackTrace();
  309. sTmp=e.getMessage() ;
  310. }
  312. return sTmp ;
  314. }
  315. //--------------------------------------
  316. private String fc_loadClob() {
  317. Node root = document.getChildNodes().item(0);
  318.     String strName=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  319. String sTmp = "";
  320. //System.out.println("1:"+strSql) ;
  321. //java.sql.Blob myBlob     = null;
  322.     java.sql.Clob myClob     = null;
  323.     java.sql.Clob myClob1     = null;
  324.   // set Oracle's Auto Commit feature to false. 
  325.   // This is necessary when manipulating Blobs and Clobs.
  326. // CallableStatement cstmt=null;
  327. try {
  328.       Statement readclob = con.createStatement();
  329.       readclob.execute("select * from fccell where fstrtablename='"+strName+"'");
  330.       ResultSet rsreadclob = readclob.getResultSet();
  331.             
  332.       // read the clob in as and ASCII stream, write to a character array, and display
  333.       String sTest="";
  334.       while ( rsreadclob.next() ) { 
  335.           Clob myReadClob =rsreadclob.getClob("fstrtable");    
  336.           int iLen=1;
  337.           iLen=(int)myReadClob.length();
  338.           sTest=myReadClob.getSubString(1,iLen);
  339.               //System.out.println("output " +sTest );
  340.               sTmp=sTest;
  341.       }        
  343. }
  344. catch (Exception e){
  345. e.printStackTrace();
  346. sTmp=e.getMessage() ;
  347. }
  349. return sTmp ;
  351. }
  352. //--------------------------------------
  353. private String fc_loadClob1() {
  354. //为了取另外一个备注字段值fstrTable1
  355. Node root = document.getChildNodes().item(0);
  356.     String strName=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  357. String sTmp = "";
  358. //System.out.println("1:"+strSql) ;
  359. //java.sql.Blob myBlob     = null;
  360.     java.sql.Clob myClob     = null;
  361.     java.sql.Clob myClob1     = null;
  362.   // set Oracle's Auto Commit feature to false. 
  363.   // This is necessary when manipulating Blobs and Clobs.
  364. // CallableStatement cstmt=null;
  365. try {
  366.       Statement readclob = con.createStatement();
  367.       readclob.execute("select * from fccell where fstrtablename='"+strName+"'");
  368.       ResultSet rsreadclob = readclob.getResultSet();
  369.             
  370.       // read the clob in as and ASCII stream, write to a character array, and display
  371.       String sTest="";
  372.       String sTest1="";
  373.       while ( rsreadclob.next() ) { 
  374.           Clob myReadClob =rsreadclob.getClob("fstrtable1");    
  375.           int iLen=1;
  376.           iLen=(int)myReadClob.length();
  377.           sTest=myReadClob.getSubString(1,iLen);
  378.   sTmp=sTest;
  379.               //System.out.println("output " +sTest );
  381.       }        
  383. }
  384. catch (Exception e){
  385. e.printStackTrace();
  386. sTmp=e.getMessage() ;
  387. }
  389. return sTmp ;
  391. }
  392. */
  394. //--------------------------------------
  395. //两个结果集的示例,第一个用连接池打开,第二个用一般方式打开
  396. private String twors() {
  397. // Node root = document.getChildNodes().item(0);
  398.  //   String sField=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  399.   //  String sTable=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  400. String strSql="select flngVoucherID,fstrVoucherTypeName from Voucher" ;
  401. String sTmp="";
  402. try {
  403. Statement stmt = con.createStatement();
  404. rs = stmt.executeQuery(strSql);
  405. while (rs.next()) {
  406. String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  407. String sConnStr = "jdbc:odbc:ereport"; 
  408. Class.forName(sDBDriver);
  409. Connection con1 = DriverManager.getConnection(sConnStr,"sa",""); 
  410. String sT=rs.getString(1);
  411. Statement stmt1 = con1.createStatement();
  412. rs1 = stmt1.executeQuery("select fstrAccountName from voucherdetail Where flngVoucherId="+sT);
  413. while (rs1.next()) {
  414. System.out.println("科目:"+rs1.getString(1));
  415. }
  416. }
  417. }
  418. catch (Exception e){
  419. sTmp=e.getMessage() ;
  420. }
  421. return sTmp;
  422. }
  423. //--------------------------------------
  424. private String fc_FieldToTable() {
  425. Node root = document.getChildNodes().item(0);
  426.     String sField=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  427.     String sTable=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  428. String strSql="select "+sField+" From "+sTable ;
  429. String sTmp="";
  430. try {
  431. Statement stmt = con.createStatement();
  432. rs = stmt.executeQuery(strSql);
  433. }
  434. catch (Exception e){
  435. sTmp=e.getMessage() ;
  436. }
  437. return sTmp;
  438. }
  439. //--------------------------------------
  440. private String GetDB() {
  441. Node root = document.getChildNodes().item(0);
  442.         String sConnect=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  443.         String sSql=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  444.         sSql=fcTrans(sSql);
  445.         //System.out.println(sSql);
  446.         String sR="";
  447.         String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; //建立数据库连接
  448. String sConnStr = "jdbc:odbc:"+sConnect ; 
  449. try {
  450. Class.forName(sDBDriver);
  451. con = DriverManager.getConnection(sConnStr,"sa",""); 
  452. Statement stmt = con.createStatement();
  454. rs = stmt.executeQuery(sSql);//执行查询建立结果集
  455. if (rs.next()) {
  456. sR=rs.getString(1);
  457. }
  458. rs.close();
  459. stmt.close();
  460. }
  461. catch (Exception e){
  462. sR=e.getMessage();
  463. }
  465. return sR;
  466. }
  467. //--------------------------------------
  468. private String fc_select() {
  469. Node root = document.getChildNodes().item(0);
  470.     String strSql=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  471.     String strPageNo=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  472. int iPageNo=Integer.parseInt(strPageNo,10);//页号
  473.     String strPageSize=root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  474. int iPageSize=Integer.parseInt(strPageSize,10);//页尺寸
  475. strSql=fcTrans(strSql);
  476. //System.out.println(strSql);
  477. String strX = "<root>";
  478. String sTmp = "";
  479. int iField=1;
  480. int iCount=1;
  481. int i=1;
  482. try {
  483. Statement stmt = con.createStatement();
  484. rs = stmt.executeQuery(strSql);
  485.         ResultSetMetaData rsmd=rs.getMetaData();
  486. while (rs.next()) {
  487. //每页30行
  488. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  489.         strX = strX + "<record>";
  490. iCount=rsmd.getColumnCount();
  491.         for (iField = 1 ; iField<=iCount ;iField++ ) 
  492. {
  493. //当有NULL字段名时,表示此则无需给值.用fcnull标记名区分.
  494. String colName=rsmd.getColumnName(iField);
  495. if (colName==null) {
  496. strX = strX + "<fcnull></fcnull>" ;
  497. }
  498. else {
  499. String sT=rs.getString(iField);
  500. if (sT==null) sT="";
  501.             strX = strX + "<fc>" + sT +"</fc>" ;
  502.             }
  503. }
  504.         strX = strX + "</record>";
  505.         }
  506.         i = i + 1;
  507. }
  508. i=i-1;
  509. if (i>0) {
  510. strX = strX + "<pages>"+i+"</pages>";
  511. }
  512. strX = strX + "</root>";
  513. rs.close();
  514. }
  515. catch (Exception e){
  516. sTmp=e.getMessage() ;
  517. System.out.println(sTmp);
  518. e.printStackTrace();
  519. }
  521. return strX ;
  523. }
  524. //--------------------------------------
  525. private String fc_select1() {
  526. //将页号和页尺寸两个节点从第一个子节点和第二个子节点改为第一个子节点下的第一个子节点和第二个子节点
  527. //将第二个子节点空出来给设置数据源用.
  528. //第二个子节点下将有三个子节点:数据源名称,用户名,密码.
  529. Node root = document.getChildNodes().item(0);
  530.     String strPageNo=root.getChildNodes().item(0).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  531. int iPageNo=Integer.parseInt(strPageNo,10);//页号
  532.     String strPageSize=root.getChildNodes().item(0).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  533. int iPageSize=Integer.parseInt(strPageSize,10);//页尺寸
  534. //数据源
  535.     strDataSource=root.getChildNodes().item(1).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  536.     strUserName=root.getChildNodes().item(1).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  537.     try {
  538.      strPassword=root.getChildNodes().item(1).getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  539.     }
  540.     catch (Exception e){
  541.      strPassword="";
  542.     }
  543. //-------
  545. //多SQL查询
  546. String strX = "<root>";
  547. int ii=0;
  548. int i=1;
  549. //按顺序取出SQL节点
  550. for(ii=2;ii<root.getChildNodes().getLength();ii++){
  552.     String strSql=root.getChildNodes().item(ii).getChildNodes().item(0).getNodeValue();
  554. strX=strX+fc_selectTmp(iPageNo,iPageSize,i,strSql);
  556. i=iPosition;
  557. } //For循环结束
  558. i=i-1;
  559. if (i>0) {
  560. strX = strX + "<pages>"+i+"</pages>";
  561. }
  562. strX = strX + "</root>";
  564. return strX ;
  566. }
  567. //--------------------------------------
  568. //计算一个SQL查询,供fc_select1 fc_select2类函数使用
  569. private String fc_selectTmp(int iPageNo,int iPageSize,int iPos,String strSql) {
  570. //iPageNo为起始页号,iPageSize为页尺寸,iPos为所有查询结果的行位置,strSql为要执行的SQL语句
  571. //返回SQL语句的运行结果,结果为以<record>...</record>形式的XML串
  572. //
  573. strSql=fcTrans(strSql);
  576. String sTmp = "";
  577. String strX = "";
  578. int iField=1;
  579. int iCount=1;
  580. int i=iPos;
  581. try {
  583. //String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  584. //String sConnStr = "jdbc:odbc:"+strDataSource; 
  585. //Class.forName(sDBDriver);
  586. //Connection conTmp = DriverManager.getConnection(sConnStr,strUserName,strPassword); 
  588. Statement stmtTmp = con.createStatement();
  589. ResultSet rsTmp = stmtTmp.executeQuery(strSql);
  590.         ResultSetMetaData rsmdTmp=rsTmp.getMetaData();
  591. while (rsTmp.next()) {
  592. //每页30行
  593. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  594.         strX = strX + "<record>";
  595. iCount=rsmdTmp.getColumnCount();
  596.         for (iField = 1 ; iField<=iCount ;iField++ ) 
  597. {
  598. //当有NULL字段名时,表示此则无需给值.用fcnull标记名区分.
  599. String colName=rsmdTmp.getColumnName(iField);
  600. if (colName==null) {
  601. strX = strX + "<fcnull></fcnull>" ;
  602. }
  603. else {
  604. String sT=rsTmp.getString(iField);
  605. if (sT==null) sT="";
  606.             strX = strX + "<fc>" + sT +"</fc>" ;
  607.             }
  608. }
  609.         strX = strX + "</record>";
  610.         }
  611.         i = i + 1;
  612. }
  614. rsTmp.close();
  615. stmtTmp.close();
  616. con.close();
  617. }
  618. catch (Exception e){
  619. sTmp=e.getMessage() ;
  620. System.out.println("0712:"+sTmp);
  621. System.out.println("0712:"+strSql);
  622. }
  623. iPosition=i; //用iPosition全局变量将i值传到调用函数中.
  624. //System.out.println("strX="+strSql);
  625. return strX;
  626. }
  627. //--------------------------------------
  628. //带分组小计的多SQL查询
  629. private String fc_select2() {
  630. //sXml的结构:
  631. //1页号 2页尺寸 3主SQL<1SQL语句 2<before... > > 4Group<1SQL语句 2GroupField >
  632. int i=1;
  633. String beforeSum="0"; //＝0表示合计行在后，＝1表示合计行在前。
  634. String strX = "";
  635. String strX1 = "";
  636. String strRetXml = ""; //返回的总的Xml串
  637. //将页号和页尺寸两个节点从第一个子节点和第二个子节点改为第一个子节点下的第一个子节点和第二个子节点
  638. //将第二个子节点空出来给设置数据源用.
  639. //第二个子节点下将有三个子节点:数据源名称,用户名,密码.
  640. Node root = document.getChildNodes().item(0);
  641.     String strPageNo=root.getChildNodes().item(0).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  642. int iPageNo=Integer.parseInt(strPageNo,10);//页号
  643.     String strPageSize=root.getChildNodes().item(0).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  644. int iPageSize=Integer.parseInt(strPageSize,10);//页尺寸
  645. //数据源
  646.     strDataSource=root.getChildNodes().item(1).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  647.     strUserName=root.getChildNodes().item(1).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  648.     try {
  649.      strPassword=root.getChildNodes().item(1).getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  650.     }
  651.     catch (Exception e){
  652.      strPassword="";
  653.     }
  654. //-------
  656. //第3个子节点的第1个子节点的值用如下求法.
  657.     String strSql=root.getChildNodes().item(2).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  658. //strSql=fcTrans(strSql);
  659. //System.out.println(strSql);
  661. //第3个子节点的第2个子节点下的第1个子节点的值用如下求法.
  662.     String strStartXml=""; //首合计行的xml串
  663.     //总计行之类的
  664.     try {
  665.      //如有一个节点表示首合计行，如有二个节点表示第一为首合计行，第二为尾合计行
  666.     String sStartSql=root.getChildNodes().item(2).getChildNodes().item(1).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  667. //此处现只假定只有一个查询,如有多个,则此处要用循环
  668. strStartXml=fc_selectTmp(iPageNo,iPageSize,i,sStartSql);
  669. i=iPosition;
  670. }
  671. catch (Exception e){
  672. }
  673. //-----------------
  675. String sGroup1="";
  676. String sGroup2="";
  677. //String sGroup3="";
  678. //第一个分组
  679.     sGroup1=root.getChildNodes().item(3).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  681. sGroup1=fcTrans(sGroup1);
  682. //分组字段名
  683.     String sGroupField1=root.getChildNodes().item(3).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  684. //第二个分组
  685.     sGroup2=root.getChildNodes().item(4).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  686. sGroup2=fcTrans(sGroup2);
  687.     String sGroupField2=root.getChildNodes().item(4).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  689. String sTmp = "";
  690. int iField=1;
  691. int iCount=1;
  692. String sGroupKey1=""; //保存分组字段的值
  693. String sGroupKey2="";
  695. String tmpsGroup="";
  696. try {
  697. String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  698. String sConnStr = "jdbc:odbc:"+strDataSource; 
  699. Class.forName(sDBDriver);
  700. Connection con1 = DriverManager.getConnection(sConnStr,strUserName,strPassword); 
  701. Statement stmt1 = con1.createStatement();
  702. Connection con2 = DriverManager.getConnection(sConnStr,strUserName,strPassword); 
  703. Statement stmt2 = con2.createStatement();
  704. rs1 = stmt1.executeQuery(sGroup1);
  705.         ResultSetMetaData rsmd1=rs1.getMetaData();
  707. while (rs1.next()) {
  708. //strX="";
  709. //strX1="";
  710. sGroupKey1=rs1.getString(1);
  712. //算出第一个分组的合计行值
  713. //if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  714.         strX = "<recordsum1>"; //设特别tagName用于在前台设底色等属性
  715. iCount=rsmd1.getColumnCount();
  716.         //第一个字段是分组字段值,所以从2开始
  717.         for (iField = 2 ; iField<=iCount ;iField++ ) 
  718. {
  719. //当有NULL字段名时,表示此则无需给值.用fcnull标记名区分.
  720. String colName=rsmd1.getColumnName(iField);
  721. if (colName==null) {
  722. strX = strX + "<fcnull></fcnull>" ;
  723. }
  724. else {
  725. String sT=rs1.getString(iField);
  726. if (sT==null) sT="";
  727. if(iField == 2)
  728. strX = strX + "<fc>小计 " + sT +"</fc>" ;
  729. else 
  730.              strX = strX + "<fc>" + sT +"</fc>" ;
  731.             }
  732. }
  733.         strX = strX + "</recordsum1>";
  734.         //}
  735.         
  737. if(sGroup2.equals("fcnull")){
  738. //只有一级分组
  739. //准备下一个的SQL语句
  740. tmpsGroup=fc_RepStr(strSql,"1999=1999","1999=1999"+" and " +sGroupField1+"='"+sGroupKey1+"'");
  741. //此处定合计行在明细行的前面还是后面
  742. if(beforeSum.equals("1")){
  743. //-------合计行在前
  744. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  745. strRetXml+=strX;
  746. }
  747. i++;
  748. strRetXml+=fc_selectTmp(iPageNo,iPageSize,i,tmpsGroup);
  749. i=iPosition;
  750. }
  751. else {
  752. //-------合计行在后
  753. strRetXml+=fc_selectTmp(iPageNo,iPageSize,i,tmpsGroup);
  754. i=iPosition;
  755. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  756. strRetXml+=strX;
  757. }
  758. i++;
  759. }
  760. }
  761. else { //有二级分组
  763. //准备下一个的SQL语句
  764. tmpsGroup=fc_RepStr(sGroup2,"1999=1999","1999=1999"+" and " +sGroupField1+"='"+sGroupKey1+"'");
  766. //System.out.println("my:"+tmpsGroup);
  767. rs2 = stmt2.executeQuery(tmpsGroup);
  768.         ResultSetMetaData rsmd2=rs2.getMetaData();
  770. if(beforeSum.equals("1")){
  771. //-------合计行在前
  772. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  773. strRetXml+=strX;
  774. }
  775. i++;
  776. }
  778. while (rs2.next()) {
  779. sGroupKey2=rs2.getString(1);
  780. //算出第二个分组的合计行值
  781.         strX1 =  "<recordsum2>";
  782. iCount=rsmd2.getColumnCount();
  783.         //第一个字段是分组字段值,所以从2开始
  784.         for (iField = 2 ; iField<=iCount ;iField++ ) 
  785. {
  786. //当有NULL字段名时,表示此则无需给值.用fcnull标记名区分.
  787. String colName=rsmd2.getColumnName(iField);
  788. if (colName==null) {
  789. strX1 = strX1 + "<fcnull></fcnull>" ;
  790. }
  791. else {
  792. String sT=rs2.getString(iField);
  793. if (sT==null) sT="";
  794. if(iField == 2)
  795. strX1 = strX1 + "<fc>小 计 " + sT +"</fc>" ;
  796. else 
  797.             strX1 = strX1 + "<fc>" + sT +"</fc>" ;
  798.             }
  799. }
  800.         strX1 = strX1 + "</recordsum2>";
  801. //-------------------------------
  803. //准备下一个的SQL语句
  804. tmpsGroup=fc_RepStr(strSql,"1999=1999","1999=1999"+" and " +sGroupField1+"='"+sGroupKey1+"'"+" and " +sGroupField2+"='"+sGroupKey2+"'");
  805. //此处定合计行在明细行的前面还是后面
  806. if(beforeSum.equals("1")){
  807. //-------合计行在前
  808. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  809. strRetXml+=strX1;
  810. }
  811. i++;
  812. strRetXml+=fc_selectTmp(iPageNo,iPageSize,i,tmpsGroup);
  813. i=iPosition;
  814. }
  815. else {
  816. //-------合计行在后
  817. strRetXml+=fc_selectTmp(iPageNo,iPageSize,i,tmpsGroup);
  818. i=iPosition;
  819. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  820. strRetXml+=strX1;
  821. }
  822. i++;
  823. }
  825. }//二级分组的循环结束
  827. if(beforeSum.equals("0")){
  828. //-------合计行在后
  829. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  830. strRetXml+=strX;
  831. }
  832. i++;
  833. }
  834. } //判断有无二级分组的IF结束
  835. }//一级分组的循环结束
  836. //----- loop end
  838. //第3个子节点(mainsql)的第3个子节点下(end)的第1个子节点(sql)的值用如下求法.
  839.     String strEndXml=""; //首合计行的xml串
  840.     //总计行之类的
  841.     try {
  842.      //如有一个节点表示首合计行，如有二个节点表示第一为首合计行，第二为尾合计行
  843.     String sStartSql=root.getChildNodes().item(2).getChildNodes().item(2).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  844. //System.out.println("endsql:"+sStartSql);
  845. //此处现只假定只有一个查询,如有多个,则此处要用循环
  846. strEndXml=fc_selectTmp(iPageNo,iPageSize,i,sStartSql);
  847. i=iPosition;
  848. }
  849. catch (Exception e){
  850. }
  851. //-----------------
  853. i=i-1;
  854. if (i>0) {
  855. strRetXml = strStartXml+strRetXml +strEndXml+ "<pages>"+i+"</pages>";
  856. }
  857. strRetXml = "<root>"+strRetXml + "</root>";
  858. //rs.close();
  859. }
  860. catch (Exception e){
  861. e.printStackTrace() ;
  862. sTmp=e.getMessage() ;
  863. System.out.println("071201"+sTmp);
  864. }
  866. return strRetXml ;
  868. }
  871. //--------------------------------------
  872. private String fc_insert() {
  873. Node root = document.getChildNodes().item(0);
  874.     String strSql=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  875. strSql=fcTrans(strSql);
  876. String sTmp = "";
  877. // CallableStatement cstmt=null;
  878. try {
  879. Statement stmt = con.createStatement();
  880. // stmt.executeQuery(strSql);
  882. stmt.executeUpdate(strSql);
  883. /*
  884. cstmt=con.prepareCall("{call sp_getID(?)}");
  885. cstmt.registerOutParameter(1,java.sql.Types.INTEGER,1);
  886. cstmt.executeUpdate();
  887. sTmp="<dsnID>"+ cstmt.getInt(1)+"</dsnID>";
  888. */
  889. }
  890. catch (Exception e){
  891. sTmp=e.getMessage() ;
  892. }
  894. return sTmp ;
  896. }
  897. //--------------------------------------
  898. private String fc_insert1() {
  899. //凭证增加
  900. Node root = document.getChildNodes().item(0);
  901. String sTmp = "";
  902. CallableStatement cstmt=null;
  903. try {
  904. Statement stmt = con.createStatement();
  905. int i;
  906. //System.out.println(root.getChildNodes().getLength());
  907.     String strSql=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  908. strSql=fcTrans(strSql);
  909. stmt.executeUpdate(strSql);
  911. String sID="1"; //存主表新生成的ID
  913. try {
  914. //SQL Server 的存储过程,用于计算自动ID
  915. cstmt=con.prepareCall("{call sp_getID(?)}");
  916. cstmt.registerOutParameter(1,java.sql.Types.INTEGER,1);
  917. cstmt.executeUpdate();
  918. sID=""+cstmt.getInt(1);
  919. }
  920. catch (Exception e1){
  921. try {
  922. //计算MS Access数据库的主表ID
  923. String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  924. String sConnStr = "jdbc:odbc:webprint"; 
  925. Class.forName(sDBDriver);
  926. Connection con1 = DriverManager.getConnection(sConnStr,"sa",""); 
  927. Statement stmt1 = con1.createStatement();
  928. rs1 = stmt1.executeQuery("select max(flngSendOutID) From SendOut");
  929. if (rs1.next()) {
  930. sID=rs1.getString(1);
  931. }
  932. }
  933. catch (Exception e2){
  934. }
  935. }
  937. //追加子表内容
  938. for(i=1;i<root.getChildNodes().getLength();i++) {
  939.     strSql=root.getChildNodes().item(i).getChildNodes().item(0).getNodeValue();
  940. strSql=fcTrans(strSql);
  941. strSql=strSql+sID+" )";
  942. stmt.executeUpdate(strSql);
  943. }
  945. }
  946. catch (Exception e){
  947. System.out.println(e.getMessage()) ;
  948. }
  950. return sTmp ;
  952. }
  953. //--------------------------------------
  954. private String fc_update1() {
  955. //凭证修改
  956. Node root = document.getChildNodes().item(0);
  957. String sTmp = "";
  958. String strSql="";
  959. try {
  960. Statement stmt = con.createStatement();
  961. int i;
  963. for(i=0;i<root.getChildNodes().getLength();i++) {
  964.     strSql=root.getChildNodes().item(i).getChildNodes().item(0).getNodeValue();
  965. strSql=fcTrans(strSql);
  966. stmt.executeUpdate(strSql);
  967. }
  969. }
  970. catch (Exception e){
  971. System.out.println(e.getMessage()) ;
  972. }
  974. return sTmp ;
  976. }
  977. //--------------------------------------
  978. /**
  979. *检查SQL语句是否为合法的SQL语句
  980. *@param sql 要检查的SQL语句.
  981. *@return 是则返回空,否则返回非空
  982. *@date 2002-05-20
  983. **/
  984. private String checksql() {
  985. Node root = document.getChildNodes().item(0);
  986.     String strSql=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  988. strSql=fcTrans(strSql);
  989. //System.out.println(strSql);
  990. String strX = "";
  991. try {
  992. Statement stmt = con.createStatement();
  993. rs = stmt.executeQuery(strSql);
  994. rs.close();
  995. }
  996. catch (Exception e){
  997. strX=e.getMessage() ;
  998. }
  1000. return strX ;
  1002. }
  1004. //--------------------------------------
  1005. private String fillcombox() {
  1006. //拼成的XML串的节点名为option,可以直接填入combox中
  1007. //返回的XML串无根节点.
  1008. Node root = document.getChildNodes().item(0);
  1009.     String strSql=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  1010. /*
  1011.     String strPageNo=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  1012. int iPageNo=Integer.parseInt(strPageNo,10);//页号
  1013.     String strPageSize=root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  1014. int iPageSize=Integer.parseInt(strPageSize,10);//页尺寸
  1015. */
  1016. strSql=fcTrans(strSql);
  1017. //System.out.println(strSql);
  1018. String strX = "";
  1019. String sTmp = "";
  1020. int iField=1;
  1021. int iCount=1;
  1022. int i=1;
  1023. try {
  1024. Statement stmt = con.createStatement();
  1025. rs = stmt.executeQuery(strSql);
  1026.          ResultSetMetaData rsmd=rs.getMetaData();
  1027. iCount=rsmd.getColumnCount();
  1028.                 String sT="";
  1029. while (rs.next()) {
  1030. //每页30行
  1031. //if ((i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) || iPageSize==-1) {
  1032.         //strX = strX + "<option>";
  1033. if(iCount>1){
  1034. //假定两列时,第一列为value,第二列为text
  1035.    sT=rs.getString(1);
  1036.    if (sT==null) sT="";
  1037.    strX+="<option value='" +sT;
  1038.    sT=rs.getString(2);
  1039.    if (sT==null) sT="";
  1040.    strX+="' >"+sT+"</option>";
  1041. }else {
  1042. //一列时则value和text相同
  1043.    sT=rs.getString(1);
  1044.    if (sT==null) sT="";
  1045.    strX+="<option value='" +sT;
  1046.    strX+="' >"+sT+"</option>";
  1048. }
  1049. //                 }
  1050.                 i = i + 1;
  1051. }
  1052. //strX = strX + "</root>";
  1053. rs.close();
  1054. }
  1055. catch (Exception e){
  1056. sTmp=e.getMessage() ;
  1057. System.out.println(sTmp);
  1058. }
  1060. return strX ;
  1062. }
  1064. //--------------------------------------
  1065. private String SqlToField(String strSql) {
  1066. //用一个SQL语句返回一个字段的第一个记录值
  1067. String strR =  "";
  1068. try {
  1069. Statement stmt = con.createStatement();
  1070. rs = stmt.executeQuery(strSql);
  1071. if (rs.next()) {
  1072.     strR = rs.getString(1) ;
  1073. }
  1074. rs.close();
  1075. stmt.close();
  1076. }
  1077. catch (Exception e){
  1078. //out.println("读表发生错误");
  1079. }
  1080. return strR;
  1082. }
  1083. //--------------------------------------
  1084. //报表增加
  1085. //--------------------------------------
  1086. private String GetReportCell() {
  1087. //找到指定位置的单元的值.
  1088. Node root = document.getChildNodes().item(0);
  1089. String sRow = root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  1090. int iRow=Integer.parseInt(sRow,10);
  1091. String sCol =root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  1092. int iCol=Integer.parseInt(sCol,10);
  1093. String strTableName =root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  1094. strTableName=fcTrans(strTableName);
  1095. //int iRow=Integer.parseInt(sRow,10);
  1096. String strSql="";
  1097. //String strID=TableNameToID(strTableName);
  1098. //strSql = "Select fstrDiv1 From cellsheet where flngID=" + strID + " and flngSheetNo=" + strPage  ;
  1099. strSql = "Select fstrTable1 From fcCell where fstrTableName='" + strTableName+"'"  ;
  1101. //String sLogCol=ToLogCol(sRow,sCol,"Select fstroCoor From cellsheet where flngID=" + strID + " and flngSheetNo=" + strPage );
  1102. //int iCol=Integer.parseInt(sLogCol,10);
  1103. String strR="";
  1104. String strR1="";
  1105. int iStart=0;
  1106. int iStartTmp=0;
  1107. int iTmp=0;
  1108. int iEnd=0;
  1109. try {
  1110. Statement stmt = con.createStatement();
  1111. rs = stmt.executeQuery(strSql);
  1112. if (rs.next()) {
  1113.     strR = rs.getString(1) ;
  1114. }
  1116. rs.close();
  1117. stmt.close();
  1118. //strR1=strR;
  1119. //查找定位TR TD
  1120. //iStart=strR.indexOf("%20id%3Dt%20",0);//查找 id=t 
  1121. for (int i=0;i<=iRow;i++) {
  1122. iStartTmp=strR.indexOf("%3CTR",iStart+1);//TR开始符
  1123. if (iStartTmp>0) {
  1124. iStart=iStartTmp;
  1125. }
  1126. }
  1127. if (iStartTmp>0) {
  1128. for (int i=0;i<=iCol;i++) {
  1129. iStartTmp=strR.indexOf("%3CTD",iStart+1); //TD开始符
  1130. if (iStartTmp>0) {
  1131. iStart=iStartTmp;
  1132. }
  1133. }
  1134. iStart=strR.indexOf("%3E",iStart);//TD后的第一个>
  1135. iEnd=strR.indexOf("%3C/TD%3E",iStart);//TD结束符
  1136. if (iEnd>iStart && iStart>0) {
  1137. strR=strR.substring(iStart+3,iEnd);
  1138. }
  1139. }
  1140. }
  1141. catch (Exception e){
  1142. System.out.println(e.getMessage());
  1143. }
  1144. //return Integer.toString(iEnd) ;
  1145. System.out.println(strR);
  1146. return "<root>"+strR+"</root>";
  1147. }
  1149. //--------------------------------------
  1156. //--------------------------------------
  1157. //通用函数
  1158. private  String fc_RepStr(String mainStr,String findStr,String replaceStr){
  1159. //多次替代
  1160. int iStart=0;
  1161. int iEnd=0;
  1162. String sRet="";
  1163. while (iStart<mainStr.length()) {
  1164. iEnd=mainStr.indexOf(findStr,iStart);
  1165. if (iEnd<0) {
  1166. iEnd=mainStr.length();
  1167. sRet=sRet+mainStr.substring(iStart,iEnd);
  1168. }
  1169. else {
  1170. sRet=sRet+mainStr.substring(iStart,iEnd)+replaceStr;
  1171. }
  1172. iStart=iEnd+findStr.length();
  1174. }
  1175. return sRet;
  1176. }
  1178. private String rTrim(String str){
  1179.      String rstr = str;
  1180.   if(str == null)
  1181.          {
  1182.     rstr = "";
  1183.   }
  1184.          else
  1185.          {
  1186.     if(str.length() == 0) rstr = "";
  1187.     if(str.length() > 0)
  1188.     {
  1189.       for(int i = str.length() ; i  >  0 ; i--)
  1190.              {
  1191.      if(str.substring(i-1,i).equals(" "))  
  1192.        rstr = rstr.substring(0,i-1);
  1193.      else break;
  1194.    }
  1195.      } 
  1196.        
  1197.   }
  1198.   return rstr;
  1199. } 
  1201. //--------------------------------------------
  1202. private String  XmlOut(ResultSet oRs , String sRowEntityName,long EntFormat ) 
  1203. {
  1204. String sSet="";
  1205. try {
  1206. //oRs.first();
  1207. while (oRs.next())
  1208. {
  1209.     sSet = sSet + RecordToXMLEntity(oRs, sRowEntityName, EntFormat) ;
  1210. }
  1211. }
  1212. catch (Exception e)
  1213. {
  1214. return e.getMessage();
  1215. }
  1216. return sSet ;
  1217. }
  1219. private String  RecordToXMLEntity(ResultSet oRs , String EntityName,long EntFormat)
  1220. {
  1221. String sEty ="";
  1222. int iField=1;
  1223. int iCount=1;
  1224.     try {
  1225.     ResultSetMetaData rsmd=oRs.getMetaData();
  1226. iCount=rsmd.getColumnCount();
  1227. if (EntFormat==1) 
  1228. {
  1229. //属性
  1230.         sEty = "<" + EntityName ;
  1232.         for (iField = 1 ; iField<=iCount ;iField++ ) 
  1233. {
  1234.             sEty = sEty + " " + rsmd.getColumnName(iField) +"='" + oRs.getString(iField) +"'" ;
  1235. }
  1236.         sEty = sEty + "/>" + "n";
  1238. }
  1239. else
  1240. {
  1241. //节点
  1242.     sEty = "<" + EntityName +">" +"n" ;
  1243.         for (iField = 1 ; iField<=iCount ; iField++) 
  1244.         {
  1245.             sEty = sEty +"<" +  rsmd.getColumnName(iField) +">" + oRs.getString(iField) +"</" + rsmd.getColumnName(iField) +">";
  1246.         }
  1247.         sEty = sEty +"n" +"</" + EntityName +">" +"n";
  1249. }
  1250. }
  1251. catch (Exception e)
  1252. {
  1253. }
  1254. return sEty;
  1255. }
  1256. //-----------------------------------------------------
  1257. private Attr[] sortAttributes(NamedNodeMap attrs) {
  1259.     int len = (attrs != null) ? attrs.getLength() : 0;
  1260.     Attr array[] = new Attr[len];
  1261.     for ( int i = 0; i < len; i++ ) {
  1262.         array[i] = (Attr)attrs.item(i);
  1263.     }
  1264.     for ( int i = 0; i < len - 1; i++ ) {
  1265.         String name  = array[i].getNodeName();
  1266.         int    index = i;
  1267.         for ( int j = i + 1; j < len; j++ ) {
  1268.             String curName = array[j].getNodeName();
  1269.             if ( curName.compareTo(name) < 0 ) {
  1270.                 name  = curName;
  1271.                 index = j;
  1272.             }
  1273.         }
  1274.         if ( index != i ) {
  1275.             Attr temp    = array[i];
  1276.             array[i]     = array[index];
  1277.             array[index] = temp;
  1278.         }
  1279.     }
  1281.     return(array);
  1283. } // sortAttributes(NamedNodeMap):Attr[]
  1286. private  String fcTrans(String sSource) 
  1287. {
  1288. //
  1289. //XML节点中的汉字经8859_1==>UTF-8转换后用System.out.println输出正常
  1291. String unicodesR ="";
  1292. try {
  1293. byte [] by = sSource.getBytes("8859_1"); //GB2312
  1294. unicodesR = new String(by,"UTF-8");
  1295. }
  1296. catch (Exception e)
  1297. {
  1298. }
  1299. //System.out.println(unicodesR);
  1300. return unicodesR;
  1301. ///
  1304. }
  1305. //--------------------------------------------
  1306. //WebCode中用
  1307. private  String sqltoxml() 
  1308. {
  1309. Node root=document.getChildNodes().item(0);
  1311. String strpage=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  1312. String strsql=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  1313. strsql=fcTrans(strsql);
  1314. String strsearch=root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  1315. String strrownum=root.getChildNodes().item(3).getChildNodes().item(0).getNodeValue();
  1316. String showcheckbox=root.getChildNodes().item(4).getChildNodes().item(0).getNodeValue();
  1317. String blnempty=root.getChildNodes().item(5).getChildNodes().item(0).getNodeValue();
  1318. //加空行
  1319. showcheckbox=showcheckbox.toUpperCase();
  1320. int intpage=Integer.parseInt(strpage);//开始页
  1321. int intrownum=Integer.parseInt(strrownum);//页尺寸
  1322. String strX="";
  1323. try {
  1325. //建立数据库连接
  1326. strDataSource="webgrid";
  1327. strUserName="sa";
  1328. strPassword="";
  1329. String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  1330. String sConnStr = "jdbc:odbc:"+strDataSource; 
  1331. Class.forName(sDBDriver);
  1332. Connection con1 = DriverManager.getConnection(sConnStr,strUserName,strPassword); 
  1334. Statement stmt = con1.createStatement();
  1335. //原来的
  1336. //Statement stmt = con.createStatement();
  1339. //执行查询建立结果集
  1340. //-----------------
  1341. //System.out.print(strsearch);
  1342. int i=1;
  1343. if (strsearch.compareTo("###")!=0){
  1344. rs = stmt.executeQuery(strsql);
  1345. boolean bfind=false;
  1347. while(rs.next()){
  1348. String searchone=rs.getString(1);
  1349. //out.print(searchone);
  1350. if (searchone.equals(strsearch)){
  1351. bfind=true;
  1352. break;
  1353. }
  1354. i=i+1;
  1355. }
  1356. rs.close();
  1357. if (bfind==true){
  1358. if (i<=intrownum){
  1359. intpage=1;
  1360. }
  1361. else {
  1362. if (i%intrownum>0){
  1363. intpage=i/intrownum+1;
  1364. }
  1365. else {
  1366. intpage=i/intrownum;
  1367. }
  1368. }
  1369. }
  1370. //自动定位到当前选择所在值的页
  1371. }
  1372. //out.print("intpage="+intpage);
  1373. //-----------------
  1374. // System.out.print(intpage);
  1378. rs = stmt.executeQuery(strsql);
  1380. ResultSetMetaData rsmd=rs.getMetaData();
  1382. strX="<root>";
  1383. String sLabel="";
  1384. int k=0;
  1385. int thisrow=0;
  1386. int pagenumber=0;//总页数
  1387. int iFind=0; //控制在开始处插入一个空白行
  1388. while (rs.next()) {
  1389. if (blnempty.equals("true") && iFind==0) {
  1390. //插入一个空白行
  1391. strX=strX+"<tr height='16'>";
  1392. for (i=1;i<=rsmd.getColumnCount();i++) {
  1393.         strX = strX + "<td></td>";
  1394. }
  1395. strX=strX+"</tr>";
  1396. iFind=1;
  1397. }
  1399. if (k>=(intpage-1)*intrownum && k<(intpage)*intrownum){
  1400. strX = strX + "<tr>";
  1401. for (i=1;i<=rsmd.getColumnCount();i++) {
  1402.         sLabel=rsmd.getColumnLabel(i);
  1403.         //System.out.println(rsmd.getColumnTypeName(i));
  1404. String sT=rs.getString(i);
  1405. if (sT==null) sT="";
  1406.         strX = strX + "<td>" + sT + "</td>";
  1407. }
  1408. if (showcheckbox.equals("TRUE"))
  1409.   strX = strX + "<td width='30'><input type='checkbox'></input></td>"+"</tr>";
  1410.                 else 
  1411.                     strX = strX + "</tr>";
  1412. }
  1413. k=k+1;
  1414. }
  1416. if (k%intrownum>0)
  1417.      pagenumber=k/intrownum+1;
  1418.         else 
  1419.             pagenumber=k/intrownum;
  1421. strX=strX+"<pagenumber>"+pagenumber+"</pagenumber><intpage>"+intpage+"</intpage></root>";
  1424. } catch (Exception e){
  1425. strX=e.getMessage();
  1426. }
  1427. return strX;
  1428. }
  1430. }