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

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

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;
  27. import javax.naming.Context;
  28. import javax.naming.InitialContext;
  29. import javax.naming.NamingException;
  30. import javax.sql.DataSource;
  32. public class WebPrint extends HttpServlet {
  33. private int iPosition=1; //用于fc_select类查询中传位置参数
  34. //数据源名称,用户名,密码.用于报表查询时连接另外的数据源使用,用于fc_select1,fc_select2
  35. private String strDataSource=""; 
  36. private String strUserName="";
  37. private String strPassword="";
  39. private String strXml="";
  40. private ResultSet rs = null;
  41. private ResultSet rs1 = null;
  42. private ResultSet rs2 = null;
  43. private Connection con = null;
  44. //private ConnectionManager cm=null;
  45. private Document document=null;
  46. private javax.sql.DataSource ds=null;
  47.   public void init() {
  49.     try  {
  51.       /* Create a connection to the WebLogic JNDI Naming Service:
  52.        */
  53.       javax.naming.InitialContext ctx = new InitialContext();
  55.       /*  Create a new DataSource by Locating It in the Naming Service:
  56.           OracleThinPool is the name of the connection pool name configed in the WebLogic server container.
  57.           WebLogic data connection pool configration:
  58.           {
  59.            URL:                     jdbc:oracle:thin:@pyds:1521:toptais  //"toptais" is database name in our RDBMS. "pyds" is DB server name.
  60.             Driver Classname:        oracle.jdbc.driver.OracleDriver
  61.             Properties (key=value):  user=scott
  62.                                      password=tiger
  63.                                      dll=ocijdbc8
  64.                                      protocol=thin
  65.           }
  66.        */
  67.       ds = (javax.sql.DataSource) 
  68.         ctx.lookup ("sqlpool");
  70.     } catch (Exception E) {
  71.       /* 
  72.          Handle exception here. 
  73.       */
  74.       System.out.println("Init Error: " + E);
  75.     }
  76.   }
  78.     public void doPost(HttpServletRequest req,
  79.                       HttpServletResponse res)
  80.         throws IOException, ServletException
  81.     {
  82. //设置演示版,
  83.      /*
  84.      long Time1=1026000000+23328000;
  85.      long curTime=0;
  86.      curTime=System.currentTimeMillis();
  87.      curTime=curTime/1000;
  88.     
  89.      //每天的时间为 86400
  90. if(curTime>Time1){ 
  91.      System.out.println("演示版已到期,系统将不正常!"); 
  92.      return ;
  93. }
  94. //------------------
  95. */
  96.         res.setContentType("text/html;charset=UTF-8");
  97.         PrintWriter out = res.getWriter();
  99. try {
  100.        //ServletContext application = getServletContext();
  101. //ConnectionManager cm= (ConnectionManager)application.getAttribute("fcConPoolManager");
  102. //cm=(ConnectionManager)application.getAttribute ( "fcConPoolManager" );
  103. //demo是配置文件中逻辑数据库的名字，同时也是连接池的名字
  105. // String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  106. // String sConnStr = "jdbc:odbc:ereport"; 
  107. // Class.forName(sDBDriver);
  108. // con = DriverManager.getConnection(sConnStr,"sa",""); 
  110. //con = cm.getConnection( "demo" );     //或者  con = cm.getConnection( "demo", 30000 );   //30000是不能马上取到连接时的等待时间(以毫秒计)
  111. con = ds.getConnection();
  113. //-----------------------
  114. /*
  115. Statement stmt = con.createStatement();
  116. //rs = stmt.executeQuery("SELECT * FROM test");
  117. con.setAutoCommit(false);
  118. stmt.executeUpdate("insert into test values('aaa','adfsdfsd')");
  119. int tran1=stmt.getUpdateCount();
  120. if (tran1>0){
  121. con.commit();
  122. }else{
  123. con.rollback();
  124. }
  125. // out.println("tran1="+tran1);
  126. /*String tt;
  127. while (rs.next()) {
  128. tt = rs.getString("fstr1");
  129. out.print("<LI>" + rs.getString("fstr2") + "</LI>");
  130. out.print("<pre>" + tt + "</pre>");
  131. }
  132. rs.close();*/
  133. //----------------------
  134. } catch (Exception e){
  135. //out.println("读表发生错误");
  136. System.out.println("Service Error: " + e);
  137. }
  138. /*
  139. finally {
  140. if( con != null ){
  141. cm.freeConnection( "demo", con );
  142. }
  143. }
  144. */
  145. //-------------------------------------------------------
  146. //strKey为？后的值
  147. String strKey=new String(req.getQueryString());
  148. //计算前台SEND来的XML串 存入strXml中
  149. BufferedReader in = req.getReader();
  150. String line = null;
  151. strXml="";
  152. while ((line = in.readLine()) != null) {
  153.       strXml=strXml+line;
  154.     }        
  155. //parse XML串
  156.     try {
  157.         DOMParserWrapper parser =
  158.         (DOMParserWrapper)Class.forName("dom.wrappers.DOMParser").newInstance();
  159.         document = parser.parseXml(strXml);
  160. }
  161. catch (Exception e) {
  162.     }
  163. //--------------------------------------------------------
  164. //用一个CASE语句来处理各种方法
  166. if (strKey.equals("fillcombox")) out.print(fillcombox());
  167. //用于用SQL语句填充combox
  169. if (strKey.equals("GetReportCell")) out.print(GetReportCell()); //跨表取数
  170. if (strKey.equals("fc_insert")) out.print(fc_insert());
  171. if (strKey.equals("fc_insert1")) out.print(fc_insert1()); //新增主子表
  172. if (strKey.equals("fc_update1")) out.print(fc_update1()); //新增主子表
  173. if (strKey.equals("fc_select")) out.print(fc_select());
  174. if (strKey.equals("fc_FieldToTable")) out.print(fc_FieldToTable());
  175. if (strKey.equals("GetDB")) out.print(GetDB());
  176. if (strKey.equals("fc_select1")) out.print(fc_select1()); //多个SQL同时查的查询
  177. if (strKey.equals("fc_select2")) out.print(fc_select2()); //明细和汇总都要的查询
  179. if (strKey.equals("twors")) out.print(twors());//两个结果集的测试
  180. if (strKey.equals("sqltoxml")) out.print(sqltoxml());//两个结果集的测试
  182. if (strKey.equals("dsnSetSession")) 
  183. {
  184. Node root = document.getChildNodes().item(0);
  185.         String strName=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  186.         String strValue="";
  187.         try {
  188.          //当此节点值为空时
  189.          strValue=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  190. }
  191. catch (Exception e) {   }
  193. HttpSession session = req.getSession(true);
  194. session.setAttribute(strName, strValue);
  195. out.print("");
  196. }
  197. if (strKey.equals("dsnGetSession")) 
  198. {
  199. Node root = document.getChildNodes().item(0);
  200.         String strName=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  201. HttpSession session = req.getSession(true);
  202. String strSR=session.getAttribute(strName).toString();;
  203. out.print(strSR);
  204. }
  206. if (strKey.equals("loadprint")) { 
  207. 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";
  208. out.println(strX);
  209. }
  215. }
  219. //下面是自定义的方法
  220. //--------------------------------------
  221. //两个结果集的示例,第一个用连接池打开,第二个用一般方式打开
  222. private String twors() {
  223. // Node root = document.getChildNodes().item(0);
  224.  //   String sField=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  225.   //  String sTable=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  226. String strSql="select flngVoucherID,fstrVoucherTypeName from Voucher" ;
  227. String sTmp="";
  228. try {
  229. Statement stmt = con.createStatement();
  230. rs = stmt.executeQuery(strSql);
  231. while (rs.next()) {
  232. String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  233. String sConnStr = "jdbc:odbc:ereport"; 
  234. Class.forName(sDBDriver);
  235. Connection con1 = DriverManager.getConnection(sConnStr,"sa",""); 
  236. String sT=rs.getString(1);
  237. Statement stmt1 = con1.createStatement();
  238. rs1 = stmt1.executeQuery("select fstrAccountName from voucherdetail Where flngVoucherId="+sT);
  239. while (rs1.next()) {
  240. System.out.println("科目:"+rs1.getString(1));
  241. }
  242. }
  243. }
  244. catch (Exception e){
  245. sTmp=e.getMessage() ;
  246. }
  247. return sTmp;
  248. }
  249. //--------------------------------------
  250. private String fc_FieldToTable() {
  251. Node root = document.getChildNodes().item(0);
  252.     String sField=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  253.     String sTable=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  254. String strSql="select "+sField+" From "+sTable ;
  255. String sTmp="";
  256. try {
  257. Statement stmt = con.createStatement();
  258. rs = stmt.executeQuery(strSql);
  259. }
  260. catch (Exception e){
  261. sTmp=e.getMessage() ;
  262. }
  263. return sTmp;
  264. }
  265. //--------------------------------------
  266. private String GetDB() {
  267. Node root = document.getChildNodes().item(0);
  268.         String sConnect=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  269.         String sSql=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  270.         sSql=fcTrans(sSql);
  271.         //System.out.println(sSql);
  272.         String sR="";
  273.         String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; //建立数据库连接
  274. String sConnStr = "jdbc:odbc:"+sConnect ; 
  275. try {
  276. Class.forName(sDBDriver);
  277. con = DriverManager.getConnection(sConnStr,"sa",""); 
  278. Statement stmt = con.createStatement();
  280. rs = stmt.executeQuery(sSql);//执行查询建立结果集
  281. if (rs.next()) {
  282. sR=rs.getString(1);
  283. }
  284. rs.close();
  285. stmt.close();
  286. }
  287. catch (Exception e){
  288. sR=e.getMessage();
  289. }
  291. return sR;
  292. }
  293. //--------------------------------------
  294. private String fc_select() {
  295. Node root = document.getChildNodes().item(0);
  296.     String strSql=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  297.     String strPageNo=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  298. int iPageNo=Integer.parseInt(strPageNo,10);//页号
  299.     String strPageSize=root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  300. int iPageSize=Integer.parseInt(strPageSize,10);//页尺寸
  301. strSql=fcTrans(strSql);
  302. //System.out.println("fc_select:"+strSql);
  303. String strX = "<root>";
  304. String sTmp = "";
  305. int iField=1;
  306. int iCount=1;
  307. int i=1;
  308. try {
  309. Statement stmt = con.createStatement();
  310. rs = stmt.executeQuery(strSql);
  311.         ResultSetMetaData rsmd=rs.getMetaData();
  312. while (rs.next()) {
  313. //每页30行
  314. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  315.         strX = strX + "<record>";
  316. iCount=rsmd.getColumnCount();
  317.         for (iField = 1 ; iField<=iCount ;iField++ ) 
  318. {
  319. //当有NULL字段名时,表示此则无需给值.用fcnull标记名区分.
  320. String colName=rsmd.getColumnName(iField);
  321. if (colName==null) {
  322. strX = strX + "<fcnull></fcnull>" ;
  323. }
  324. else {
  325. String sT=rs.getString(iField);
  326. if (sT==null) sT="";
  327.             strX = strX + "<fc>" + sT +"</fc>" ;
  328.             }
  329. }
  330.         strX = strX + "</record>";
  331.         }
  332.         i = i + 1;
  333. }
  334. i=i-1;
  335. if (i>0) {
  336. strX = strX + "<pages>"+i+"</pages>";
  337. }
  338. strX = strX + "</root>";
  339. rs.close();
  340. }
  341. catch (Exception e){
  342. sTmp=e.getMessage() ;
  343. System.out.println(sTmp);
  344. e.printStackTrace();
  345. }
  347. return strX ;
  349. }
  350. //--------------------------------------
  351. private String fc_select1() {
  352. //将页号和页尺寸两个节点从第一个子节点和第二个子节点改为第一个子节点下的第一个子节点和第二个子节点
  353. //将第二个子节点空出来给设置数据源用.
  354. //第二个子节点下将有三个子节点:数据源名称,用户名,密码.
  355. Node root = document.getChildNodes().item(0);
  356.     String strPageNo=root.getChildNodes().item(0).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  357. int iPageNo=Integer.parseInt(strPageNo,10);//页号
  358.     String strPageSize=root.getChildNodes().item(0).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  359. int iPageSize=Integer.parseInt(strPageSize,10);//页尺寸
  360. //数据源
  361.     strDataSource=root.getChildNodes().item(1).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  362.     strUserName=root.getChildNodes().item(1).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  363.     try {
  364.      strPassword=root.getChildNodes().item(1).getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  365.     }
  366.     catch (Exception e){
  367.      strPassword="";
  368.     }
  369. //-------
  371. //多SQL查询
  372. String strX = "<root>";
  373. int ii=0;
  374. int i=1;
  375. //按顺序取出SQL节点
  376. for(ii=2;ii<root.getChildNodes().getLength();ii++){
  378.     String strSql=root.getChildNodes().item(ii).getChildNodes().item(0).getNodeValue();
  380. strX=strX+fc_selectTmp(iPageNo,iPageSize,i,strSql);
  382. i=iPosition;
  383. } //For循环结束
  384. i=i-1;
  385. if (i>0) {
  386. strX = strX + "<pages>"+i+"</pages>";
  387. }
  388. strX = strX + "</root>";
  390. return strX ;
  392. }
  393. //--------------------------------------
  394. //计算一个SQL查询,供fc_select1 fc_select2类函数使用
  395. private String fc_selectTmp(int iPageNo,int iPageSize,int iPos,String strSql) {
  396. //iPageNo为起始页号,iPageSize为页尺寸,iPos为所有查询结果的行位置,strSql为要执行的SQL语句
  397. //返回SQL语句的运行结果,结果为以<record>...</record>形式的XML串
  398. //
  399. strSql=fcTrans(strSql);
  402. String sTmp = "";
  403. String strX = "";
  404. int iField=1;
  405. int iCount=1;
  406. int i=iPos;
  407. try {
  409. //String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  410. //String sConnStr = "jdbc:odbc:"+strDataSource; 
  411. //Class.forName(sDBDriver);
  412. Connection conTmp = ds.getConnection();
  414. Statement stmtTmp = conTmp.createStatement();
  415. ResultSet rsTmp = stmtTmp.executeQuery(strSql);
  416.         ResultSetMetaData rsmdTmp=rsTmp.getMetaData();
  417. while (rsTmp.next()) {
  418. //每页30行
  419. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  420.         strX = strX + "<record>";
  421. iCount=rsmdTmp.getColumnCount();
  422.         for (iField = 1 ; iField<=iCount ;iField++ ) 
  423. {
  424. //当有NULL字段名时,表示此则无需给值.用fcnull标记名区分.
  425. String colName=rsmdTmp.getColumnName(iField);
  426. if (colName==null) {
  427. strX = strX + "<fcnull></fcnull>" ;
  428. }
  429. else {
  430. String sT=rsTmp.getString(iField);
  431. if (sT==null) sT="";
  432.             strX = strX + "<fc>" + sT +"</fc>" ;
  433.             }
  434. }
  435.         strX = strX + "</record>";
  436.         }
  437.         i = i + 1;
  438. }
  440. rsTmp.close();
  441. stmtTmp.close();
  442. conTmp.close();
  443. }
  444. catch (Exception e){
  445. sTmp=e.getMessage() ;
  446. System.out.println("0712:"+sTmp);
  447. System.out.println("0712:"+strSql);
  448. }
  449. iPosition=i; //用iPosition全局变量将i值传到调用函数中.
  451. //System.out.println("strX中文="+strX);
  452. strX=fcTrans1(strX);
  453. /*
  454. System.out.println("1="+strX1);
  455. String strX2=fcTrans2(strX);
  456. System.out.println("2="+strX2);
  457. String strX3=fcTrans(strX);
  458. System.out.println("3="+strX3);
  459. */
  460. return strX;
  461. }
  462. //--------------------------------------
  463. //带分组小计的多SQL查询
  464. private String fc_select2() {
  465. //sXml的结构:
  466. //1页号 2页尺寸 3主SQL<1SQL语句 2<before... > > 4Group<1SQL语句 2GroupField >
  467. int i=1;
  468. String beforeSum="0"; //＝0表示合计行在后，＝1表示合计行在前。
  469. String strX = "";
  470. String strX1 = "";
  471. String strRetXml = ""; //返回的总的Xml串
  472. //将页号和页尺寸两个节点从第一个子节点和第二个子节点改为第一个子节点下的第一个子节点和第二个子节点
  473. //将第二个子节点空出来给设置数据源用.
  474. //第二个子节点下将有三个子节点:数据源名称,用户名,密码.
  475. Node root = document.getChildNodes().item(0);
  476.     String strPageNo=root.getChildNodes().item(0).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  477. int iPageNo=Integer.parseInt(strPageNo,10);//页号
  478.     String strPageSize=root.getChildNodes().item(0).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  479. int iPageSize=Integer.parseInt(strPageSize,10);//页尺寸
  480. //数据源
  481.     strDataSource=root.getChildNodes().item(1).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  482.     strUserName=root.getChildNodes().item(1).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  483.     try {
  484.      strPassword=root.getChildNodes().item(1).getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  485.     }
  486.     catch (Exception e){
  487.      strPassword="";
  488.     }
  489. //-------
  491. //第3个子节点的第1个子节点的值用如下求法.
  492.     String strSql=root.getChildNodes().item(2).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  493. //strSql=fcTrans(strSql);
  494. //System.out.println(strSql);
  496. //第3个子节点的第2个子节点下的第1个子节点的值用如下求法.
  497.     String strStartXml=""; //首合计行的xml串
  498.     //总计行之类的
  499.     try {
  500.      //如有一个节点表示首合计行，如有二个节点表示第一为首合计行，第二为尾合计行
  501.     String sStartSql=root.getChildNodes().item(2).getChildNodes().item(1).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  502. //此处现只假定只有一个查询,如有多个,则此处要用循环
  503. strStartXml=fc_selectTmp(iPageNo,iPageSize,i,sStartSql);
  504. i=iPosition;
  505. }
  506. catch (Exception e){
  507. }
  508. //-----------------
  510. String sGroup1="";
  511. String sGroup2="";
  512. //String sGroup3="";
  513. //第一个分组
  514.     sGroup1=root.getChildNodes().item(3).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  516. sGroup1=fcTrans(sGroup1);
  517. //分组字段名
  518.     String sGroupField1=root.getChildNodes().item(3).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  519. //第二个分组
  520.     sGroup2=root.getChildNodes().item(4).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  521. sGroup2=fcTrans(sGroup2);
  522.     String sGroupField2=root.getChildNodes().item(4).getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  524. String sTmp = "";
  525. int iField=1;
  526. int iCount=1;
  527. String sGroupKey1=""; //保存分组字段的值
  528. String sGroupKey2="";
  530. String tmpsGroup="";
  531. try {
  532. //String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  533. //String sConnStr = "jdbc:odbc:"+strDataSource; 
  534. //Class.forName(sDBDriver);
  535. Connection con1 = ds.getConnection();  //DriverManager.getConnection(sConnStr,strUserName,strPassword); 
  536. Statement stmt1 = con1.createStatement();
  537. Connection con2 = ds.getConnection(); //DriverManager.getConnection(sConnStr,strUserName,strPassword); 
  538. Statement stmt2 = con2.createStatement();
  539. rs1 = stmt1.executeQuery(sGroup1);
  540.         ResultSetMetaData rsmd1=rs1.getMetaData();
  542. while (rs1.next()) {
  543. //strX="";
  544. //strX1="";
  545. sGroupKey1=rs1.getString(1);
  547. //算出第一个分组的合计行值
  548. //if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  549.         strX = "<recordsum1>"; //设特别tagName用于在前台设底色等属性
  550. iCount=rsmd1.getColumnCount();
  551.         //第一个字段是分组字段值,所以从2开始
  552.         for (iField = 2 ; iField<=iCount ;iField++ ) 
  553. {
  554. //当有NULL字段名时,表示此则无需给值.用fcnull标记名区分.
  555. String colName=rsmd1.getColumnName(iField);
  556. if (colName==null) {
  557. strX = strX + "<fcnull></fcnull>" ;
  558. }
  559. else {
  560. String sT=rs1.getString(iField);
  561. if (sT==null) sT="";
  562. if(iField == 2)
  563. strX = strX + "<fc>小计 " + sT +"</fc>" ;
  564. else 
  565.              strX = strX + "<fc>" + sT +"</fc>" ;
  566.             }
  567. }
  568.         strX = strX + "</recordsum1>";
  569.         //}
  570.         
  572. if(sGroup2.equals("fcnull")){
  573. //只有一级分组
  574. //准备下一个的SQL语句
  575. tmpsGroup=fc_RepStr(strSql,"1999=1999","1999=1999"+" and " +sGroupField1+"='"+sGroupKey1+"'");
  576. //此处定合计行在明细行的前面还是后面
  577. if(beforeSum.equals("1")){
  578. //-------合计行在前
  579. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  580. strRetXml+=strX;
  581. }
  582. i++;
  583. strRetXml+=fc_selectTmp(iPageNo,iPageSize,i,tmpsGroup);
  584. i=iPosition;
  585. }
  586. else {
  587. //-------合计行在后
  588. strRetXml+=fc_selectTmp(iPageNo,iPageSize,i,tmpsGroup);
  589. i=iPosition;
  590. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  591. strRetXml+=strX;
  592. }
  593. i++;
  594. }
  595. }
  596. else { //有二级分组
  598. //准备下一个的SQL语句
  599. tmpsGroup=fc_RepStr(sGroup2,"1999=1999","1999=1999"+" and " +sGroupField1+"='"+sGroupKey1+"'");
  601. //System.out.println("my:"+tmpsGroup);
  602. rs2 = stmt2.executeQuery(tmpsGroup);
  603.         ResultSetMetaData rsmd2=rs2.getMetaData();
  605. if(beforeSum.equals("1")){
  606. //-------合计行在前
  607. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  608. strRetXml+=strX;
  609. }
  610. i++;
  611. }
  613. while (rs2.next()) {
  614. sGroupKey2=rs2.getString(1);
  615. //算出第二个分组的合计行值
  616.         strX1 =  "<recordsum2>";
  617. iCount=rsmd2.getColumnCount();
  618.         //第一个字段是分组字段值,所以从2开始
  619.         for (iField = 2 ; iField<=iCount ;iField++ ) 
  620. {
  621. //当有NULL字段名时,表示此则无需给值.用fcnull标记名区分.
  622. String colName=rsmd2.getColumnName(iField);
  623. if (colName==null) {
  624. strX1 = strX1 + "<fcnull></fcnull>" ;
  625. }
  626. else {
  627. String sT=rs2.getString(iField);
  628. if (sT==null) sT="";
  629. if(iField == 2)
  630. strX1 = strX1 + "<fc>小 计 " + sT +"</fc>" ;
  631. else 
  632.             strX1 = strX1 + "<fc>" + sT +"</fc>" ;
  633.             }
  634. }
  635.         strX1 = strX1 + "</recordsum2>";
  636. //-------------------------------
  638. //准备下一个的SQL语句
  639. tmpsGroup=fc_RepStr(strSql,"1999=1999","1999=1999"+" and " +sGroupField1+"='"+sGroupKey1+"'"+" and " +sGroupField2+"='"+sGroupKey2+"'");
  640. //此处定合计行在明细行的前面还是后面
  641. if(beforeSum.equals("1")){
  642. //-------合计行在前
  643. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  644. strRetXml+=strX1;
  645. }
  646. i++;
  647. strRetXml+=fc_selectTmp(iPageNo,iPageSize,i,tmpsGroup);
  648. i=iPosition;
  649. }
  650. else {
  651. //-------合计行在后
  652. strRetXml+=fc_selectTmp(iPageNo,iPageSize,i,tmpsGroup);
  653. i=iPosition;
  654. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  655. strRetXml+=strX1;
  656. }
  657. i++;
  658. }
  660. }//二级分组的循环结束
  662. if(beforeSum.equals("0")){
  663. //-------合计行在后
  664. if (i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) {
  665. strRetXml+=strX;
  666. }
  667. i++;
  668. }
  669. } //判断有无二级分组的IF结束
  670. }//一级分组的循环结束
  671. //----- loop end
  673. //第3个子节点(mainsql)的第3个子节点下(end)的第1个子节点(sql)的值用如下求法.
  674.     String strEndXml=""; //首合计行的xml串
  675.     //总计行之类的
  676.     try {
  677.      //如有一个节点表示首合计行，如有二个节点表示第一为首合计行，第二为尾合计行
  678.     String sStartSql=root.getChildNodes().item(2).getChildNodes().item(2).getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  679. //System.out.println("endsql:"+sStartSql);
  680. //此处现只假定只有一个查询,如有多个,则此处要用循环
  681. strEndXml=fc_selectTmp(iPageNo,iPageSize,i,sStartSql);
  682. i=iPosition;
  683. }
  684. catch (Exception e){
  685. }
  686. //-----------------
  688. i=i-1;
  689. if (i>0) {
  690. strRetXml = strStartXml+strRetXml +strEndXml+ "<pages>"+i+"</pages>";
  691. }
  692. strRetXml = "<root>"+strRetXml + "</root>";
  693. //rs.close();
  694. }
  695. catch (Exception e){
  696. e.printStackTrace() ;
  697. sTmp=e.getMessage() ;
  698. System.out.println("071201"+sTmp);
  699. }
  701. return strRetXml ;
  703. }
  706. //--------------------------------------
  707. private String fc_insert() {
  708. Node root = document.getChildNodes().item(0);
  709.     String strSql=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  710. strSql=fcTrans(strSql);
  711. String sTmp = "";
  712. // CallableStatement cstmt=null;
  713. try {
  714. Statement stmt = con.createStatement();
  715. // stmt.executeQuery(strSql);
  717. stmt.executeUpdate(strSql);
  718. /*
  719. cstmt=con.prepareCall("{call sp_getID(?)}");
  720. cstmt.registerOutParameter(1,java.sql.Types.INTEGER,1);
  721. cstmt.executeUpdate();
  722. sTmp="<dsnID>"+ cstmt.getInt(1)+"</dsnID>";
  723. */
  724. }
  725. catch (Exception e){
  726. sTmp=e.getMessage() ;
  727. }
  729. return sTmp ;
  731. }
  732. //--------------------------------------
  733. private String fc_insert1() {
  734. //凭证增加
  735. Node root = document.getChildNodes().item(0);
  736. String sTmp = "";
  737. CallableStatement cstmt=null;
  738. try {
  739. Statement stmt = con.createStatement();
  740. int i;
  741. //System.out.println(root.getChildNodes().getLength());
  742.     String strSql=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  743. strSql=fcTrans(strSql);
  744. stmt.executeUpdate(strSql);
  746. String sID="1"; //存主表新生成的ID
  748. try {
  749. //SQL Server 的存储过程,用于计算自动ID
  750. cstmt=con.prepareCall("{call sp_getID(?)}");
  751. cstmt.registerOutParameter(1,java.sql.Types.INTEGER,1);
  752. cstmt.executeUpdate();
  753. sID=""+cstmt.getInt(1);
  754. }
  755. catch (Exception e1){
  756. try {
  757. //计算MS Access数据库的主表ID
  758. //String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  759. //String sConnStr = "jdbc:odbc:webprint"; 
  760. //Class.forName(sDBDriver);
  761. Connection con1 = ds.getConnection();  //DriverManager.getConnection(sConnStr,"sa",""); 
  762. Statement stmt1 = con1.createStatement();
  763. rs1 = stmt1.executeQuery("select max(flngSendOutID) From SendOut");
  764. if (rs1.next()) {
  765. sID=rs1.getString(1);
  766. }
  767. }
  768. catch (Exception e2){
  769. }
  770. }
  772. //追加子表内容
  773. for(i=1;i<root.getChildNodes().getLength();i++) {
  774.     strSql=root.getChildNodes().item(i).getChildNodes().item(0).getNodeValue();
  775. strSql=fcTrans(strSql);
  776. strSql=strSql+sID+" )";
  777. stmt.executeUpdate(strSql);
  778. }
  780. }
  781. catch (Exception e){
  782. System.out.println(e.getMessage()) ;
  783. }
  785. return sTmp ;
  787. }
  788. //--------------------------------------
  789. private String fc_update1() {
  790. //凭证修改
  791. Node root = document.getChildNodes().item(0);
  792. String sTmp = "";
  793. String strSql="";
  794. try {
  795. Statement stmt = con.createStatement();
  796. int i;
  798. for(i=0;i<root.getChildNodes().getLength();i++) {
  799.     strSql=root.getChildNodes().item(i).getChildNodes().item(0).getNodeValue();
  800. strSql=fcTrans(strSql);
  801. stmt.executeUpdate(strSql);
  802. }
  804. }
  805. catch (Exception e){
  806. System.out.println(e.getMessage()) ;
  807. }
  809. return sTmp ;
  811. }
  812. //--------------------------------------
  813. private String fillcombox() {
  814. //拼成的XML串的节点名为option,可以直接填入combox中
  815. //返回的XML串无根节点.
  816. Node root = document.getChildNodes().item(0);
  817.     String strSql=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  818. /*
  819.     String strPageNo=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  820. int iPageNo=Integer.parseInt(strPageNo,10);//页号
  821.     String strPageSize=root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  822. int iPageSize=Integer.parseInt(strPageSize,10);//页尺寸
  823. */
  824. strSql=fcTrans(strSql);
  825. //System.out.println(strSql);
  826. String strX = "";
  827. String sTmp = "";
  828. int iField=1;
  829. int iCount=1;
  830. int i=1;
  831. try {
  832. Statement stmt = con.createStatement();
  833. rs = stmt.executeQuery(strSql);
  834.          ResultSetMetaData rsmd=rs.getMetaData();
  835. iCount=rsmd.getColumnCount();
  836.                 String sT="";
  837. while (rs.next()) {
  838. //每页30行
  839. //if ((i>(iPageNo-1)*iPageSize && i<=iPageNo*iPageSize) || iPageSize==-1) {
  840.         //strX = strX + "<option>";
  841. if(iCount>1){
  842. //假定两列时,第一列为value,第二列为text
  843.    sT=rs.getString(1);
  844.    if (sT==null) sT="";
  845.    strX+="<option value='" +sT;
  846.    sT=rs.getString(2);
  847.    if (sT==null) sT="";
  848.    strX+="' >"+sT+"</option>";
  849. }else {
  850. //一列时则value和text相同
  851.    sT=rs.getString(1);
  852.    if (sT==null) sT="";
  853.    strX+="<option value='" +sT;
  854.    strX+="' >"+sT+"</option>";
  856. }
  857. //                 }
  858.                 i = i + 1;
  859. }
  860. //strX = strX + "</root>";
  861. rs.close();
  862. }
  863. catch (Exception e){
  864. sTmp=e.getMessage() ;
  865. System.out.println(sTmp);
  866. }
  868. return strX ;
  870. }
  872. //--------------------------------------
  873. private String SqlToField(String strSql) {
  874. //用一个SQL语句返回一个字段的第一个记录值
  875. String strR =  "";
  876. try {
  877. Statement stmt = con.createStatement();
  878. rs = stmt.executeQuery(strSql);
  879. if (rs.next()) {
  880.     strR = rs.getString(1) ;
  881. }
  882. rs.close();
  883. stmt.close();
  884. }
  885. catch (Exception e){
  886. //out.println("读表发生错误");
  887. }
  888. return strR;
  890. }
  891. //--------------------------------------
  892. //报表增加
  893. //--------------------------------------
  894. private String GetReportCell() {
  895. //找到指定位置的单元的值.
  896. Node root = document.getChildNodes().item(0);
  897. String sRow = root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  898. int iRow=Integer.parseInt(sRow,10);
  899. String sCol =root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  900. int iCol=Integer.parseInt(sCol,10);
  901. String strTableName =root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  902. strTableName=fcTrans(strTableName);
  903. //int iRow=Integer.parseInt(sRow,10);
  904. String strSql="";
  905. //String strID=TableNameToID(strTableName);
  906. //strSql = "Select fstrDiv1 From cellsheet where flngID=" + strID + " and flngSheetNo=" + strPage  ;
  907. strSql = "Select fstrTable1 From fcCell where fstrTableName='" + strTableName+"'"  ;
  909. //String sLogCol=ToLogCol(sRow,sCol,"Select fstroCoor From cellsheet where flngID=" + strID + " and flngSheetNo=" + strPage );
  910. //int iCol=Integer.parseInt(sLogCol,10);
  911. String strR="";
  912. String strR1="";
  913. int iStart=0;
  914. int iStartTmp=0;
  915. int iTmp=0;
  916. int iEnd=0;
  917. try {
  918. Statement stmt = con.createStatement();
  919. rs = stmt.executeQuery(strSql);
  920. if (rs.next()) {
  921.     strR = rs.getString(1) ;
  922. }
  924. rs.close();
  925. stmt.close();
  926. //strR1=strR;
  927. //查找定位TR TD
  928. //iStart=strR.indexOf("%20id%3Dt%20",0);//查找 id=t 
  929. for (int i=0;i<=iRow;i++) {
  930. iStartTmp=strR.indexOf("%3CTR",iStart+1);//TR开始符
  931. if (iStartTmp>0) {
  932. iStart=iStartTmp;
  933. }
  934. }
  935. if (iStartTmp>0) {
  936. for (int i=0;i<=iCol;i++) {
  937. iStartTmp=strR.indexOf("%3CTD",iStart+1); //TD开始符
  938. if (iStartTmp>0) {
  939. iStart=iStartTmp;
  940. }
  941. }
  942. iStart=strR.indexOf("%3E",iStart);//TD后的第一个>
  943. iEnd=strR.indexOf("%3C/TD%3E",iStart);//TD结束符
  944. if (iEnd>iStart && iStart>0) {
  945. strR=strR.substring(iStart+3,iEnd);
  946. }
  947. }
  948. }
  949. catch (Exception e){
  950. System.out.println(e.getMessage());
  951. }
  952. //return Integer.toString(iEnd) ;
  953. System.out.println(strR);
  954. return "<root>"+strR+"</root>";
  955. }
  957. //--------------------------------------
  964. //--------------------------------------
  965. //通用函数
  966. private  String fc_RepStr(String mainStr,String findStr,String replaceStr){
  967. //多次替代
  968. int iStart=0;
  969. int iEnd=0;
  970. String sRet="";
  971. while (iStart<mainStr.length()) {
  972. iEnd=mainStr.indexOf(findStr,iStart);
  973. if (iEnd<0) {
  974. iEnd=mainStr.length();
  975. sRet=sRet+mainStr.substring(iStart,iEnd);
  976. }
  977. else {
  978. sRet=sRet+mainStr.substring(iStart,iEnd)+replaceStr;
  979. }
  980. iStart=iEnd+findStr.length();
  982. }
  983. return sRet;
  984. }
  986. private String rTrim(String str){
  987.      String rstr = str;
  988.   if(str == null)
  989.          {
  990.     rstr = "";
  991.   }
  992.          else
  993.          {
  994.     if(str.length() == 0) rstr = "";
  995.     if(str.length() > 0)
  996.     {
  997.       for(int i = str.length() ; i  >  0 ; i--)
  998.              {
  999.      if(str.substring(i-1,i).equals(" "))  
  1000.        rstr = rstr.substring(0,i-1);
  1001.      else break;
  1002.    }
  1003.      } 
  1004.        
  1005.   }
  1006.   return rstr;
  1007. } 
  1009. //--------------------------------------------
  1010. private String  XmlOut(ResultSet oRs , String sRowEntityName,long EntFormat ) 
  1011. {
  1012. String sSet="";
  1013. try {
  1014. //oRs.first();
  1015. while (oRs.next())
  1016. {
  1017.     sSet = sSet + RecordToXMLEntity(oRs, sRowEntityName, EntFormat) ;
  1018. }
  1019. }
  1020. catch (Exception e)
  1021. {
  1022. return e.getMessage();
  1023. }
  1024. return sSet ;
  1025. }
  1027. private String  RecordToXMLEntity(ResultSet oRs , String EntityName,long EntFormat)
  1028. {
  1029. String sEty ="";
  1030. int iField=1;
  1031. int iCount=1;
  1032.     try {
  1033.     ResultSetMetaData rsmd=oRs.getMetaData();
  1034. iCount=rsmd.getColumnCount();
  1035. if (EntFormat==1) 
  1036. {
  1037. //属性
  1038.         sEty = "<" + EntityName ;
  1040.         for (iField = 1 ; iField<=iCount ;iField++ ) 
  1041. {
  1042.             sEty = sEty + " " + rsmd.getColumnName(iField) +"='" + oRs.getString(iField) +"'" ;
  1043. }
  1044.         sEty = sEty + "/>" + "n";
  1046. }
  1047. else
  1048. {
  1049. //节点
  1050.     sEty = "<" + EntityName +">" +"n" ;
  1051.         for (iField = 1 ; iField<=iCount ; iField++) 
  1052.         {
  1053.             sEty = sEty +"<" +  rsmd.getColumnName(iField) +">" + oRs.getString(iField) +"</" + rsmd.getColumnName(iField) +">";
  1054.         }
  1055.         sEty = sEty +"n" +"</" + EntityName +">" +"n";
  1057. }
  1058. }
  1059. catch (Exception e)
  1060. {
  1061. }
  1062. return sEty;
  1063. }
  1064. //-----------------------------------------------------
  1065. private Attr[] sortAttributes(NamedNodeMap attrs) {
  1067.     int len = (attrs != null) ? attrs.getLength() : 0;
  1068.     Attr array[] = new Attr[len];
  1069.     for ( int i = 0; i < len; i++ ) {
  1070.         array[i] = (Attr)attrs.item(i);
  1071.     }
  1072.     for ( int i = 0; i < len - 1; i++ ) {
  1073.         String name  = array[i].getNodeName();
  1074.         int    index = i;
  1075.         for ( int j = i + 1; j < len; j++ ) {
  1076.             String curName = array[j].getNodeName();
  1077.             if ( curName.compareTo(name) < 0 ) {
  1078.                 name  = curName;
  1079.                 index = j;
  1080.             }
  1081.         }
  1082.         if ( index != i ) {
  1083.             Attr temp    = array[i];
  1084.             array[i]     = array[index];
  1085.             array[index] = temp;
  1086.         }
  1087.     }
  1089.     return(array);
  1091. } // sortAttributes(NamedNodeMap):Attr[]
  1093. private  String fcTrans1(String sSource) 
  1094. {
  1095. //
  1096. //XML节点中的汉字经8859_1==>UTF-8转换后用System.out.println输出正常
  1098. String unicodesR ="";
  1099. try {
  1100. byte [] by = sSource.getBytes("8859_1"); //GB2312
  1101. unicodesR = new String(by,"GB2312");
  1102. }
  1103. catch (Exception e)
  1104. {
  1105. }
  1106. //System.out.println(unicodesR);
  1107. return unicodesR;
  1108. ///
  1111. }
  1112. private  String fcTrans2(String sSource) 
  1113. {
  1114. //
  1115. //XML节点中的汉字经8859_1==>UTF-8转换后用System.out.println输出正常
  1117. String unicodesR ="";
  1118. try {
  1119. byte [] by = sSource.getBytes("GB2312"); //GB2312
  1120. unicodesR = new String(by,"8859_1");
  1121. }
  1122. catch (Exception e)
  1123. {
  1124. }
  1125. //System.out.println(unicodesR);
  1126. return unicodesR;
  1127. ///
  1130. }
  1133. private  String fcTrans(String sSource) 
  1134. {
  1135. //
  1136. //XML节点中的汉字经8859_1==>UTF-8转换后用System.out.println输出正常
  1138. String unicodesR ="";
  1139. try {
  1140. byte [] by = sSource.getBytes("8859_1"); //GB2312
  1141. unicodesR = new String(by,"UTF-8");
  1142. }
  1143. catch (Exception e)
  1144. {
  1145. }
  1146. //System.out.println(unicodesR);
  1147. return unicodesR;
  1148. ///
  1151. }
  1152. //--------------------------------------------
  1153. //WebCode中用
  1154. private  String sqltoxml() 
  1155. {
  1156. Node root=document.getChildNodes().item(0);
  1158. String strpage=root.getChildNodes().item(0).getChildNodes().item(0).getNodeValue();
  1159. String strsql=root.getChildNodes().item(1).getChildNodes().item(0).getNodeValue();
  1160. strsql=fcTrans(strsql);
  1161. String strsearch=root.getChildNodes().item(2).getChildNodes().item(0).getNodeValue();
  1162. String strrownum=root.getChildNodes().item(3).getChildNodes().item(0).getNodeValue();
  1163. String showcheckbox=root.getChildNodes().item(4).getChildNodes().item(0).getNodeValue();
  1164. String blnempty=root.getChildNodes().item(5).getChildNodes().item(0).getNodeValue();
  1165. //加空行
  1166. showcheckbox=showcheckbox.toUpperCase();
  1167. int intpage=Integer.parseInt(strpage);//开始页
  1168. int intrownum=Integer.parseInt(strrownum);//页尺寸
  1169. String strX="";
  1170. try {
  1172. //建立数据库连接
  1173. /*
  1174. strDataSource="webgrid";
  1175. strUserName="sa";
  1176. strPassword="";
  1177. String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
  1178. String sConnStr = "jdbc:odbc:"+strDataSource; 
  1179. Class.forName(sDBDriver);
  1180. Connection con1 = DriverManager.getConnection(sConnStr,strUserName,strPassword); 
  1181. */
  1182. Connection con1 = ds.getConnection();
  1183. Statement stmt = con1.createStatement();
  1184. //原来的
  1185. //Statement stmt = con.createStatement();
  1188. //执行查询建立结果集
  1189. //-----------------
  1190. //System.out.print(strsearch);
  1191. int i=1;
  1192. if (strsearch.compareTo("###")!=0){
  1193. rs = stmt.executeQuery(strsql);
  1194. boolean bfind=false;
  1196. while(rs.next()){
  1197. String searchone=rs.getString(1);
  1198. //out.print(searchone);
  1199. if (searchone.equals(strsearch)){
  1200. bfind=true;
  1201. break;
  1202. }
  1203. i=i+1;
  1204. }
  1205. rs.close();
  1206. if (bfind==true){
  1207. if (i<=intrownum){
  1208. intpage=1;
  1209. }
  1210. else {
  1211. if (i%intrownum>0){
  1212. intpage=i/intrownum+1;
  1213. }
  1214. else {
  1215. intpage=i/intrownum;
  1216. }
  1217. }
  1218. }
  1219. //自动定位到当前选择所在值的页
  1220. }
  1221. //out.print("intpage="+intpage);
  1222. //-----------------
  1223. // System.out.print(intpage);
  1227. rs = stmt.executeQuery(strsql);
  1229. ResultSetMetaData rsmd=rs.getMetaData();
  1231. strX="<root>";
  1232. String sLabel="";
  1233. int k=0;
  1234. int thisrow=0;
  1235. int pagenumber=0;//总页数
  1236. int iFind=0; //控制在开始处插入一个空白行
  1237. while (rs.next()) {
  1238. if (blnempty.equals("true") && iFind==0) {
  1239. //插入一个空白行
  1240. strX=strX+"<tr height='16'>";
  1241. for (i=1;i<=rsmd.getColumnCount();i++) {
  1242.         strX = strX + "<td></td>";
  1243. }
  1244. strX=strX+"</tr>";
  1245. iFind=1;
  1246. }
  1248. if (k>=(intpage-1)*intrownum && k<(intpage)*intrownum){
  1249. strX = strX + "<tr>";
  1250. for (i=1;i<=rsmd.getColumnCount();i++) {
  1251.         sLabel=rsmd.getColumnLabel(i);
  1252.         //System.out.println(rsmd.getColumnTypeName(i));
  1253. String sT=rs.getString(i);
  1254. if (sT==null) sT="";
  1255.         strX = strX + "<td>" + sT + "</td>";
  1256. }
  1257. if (showcheckbox.equals("TRUE"))
  1258.   strX = strX + "<td width='30'><input type='checkbox'></input></td>"+"</tr>";
  1259.                 else 
  1260.                     strX = strX + "</tr>";
  1261. }
  1262. k=k+1;
  1263. }
  1265. if (k%intrownum>0)
  1266.      pagenumber=k/intrownum+1;
  1267.         else 
  1268.             pagenumber=k/intrownum;
  1270. strX=strX+"<pagenumber>"+pagenumber+"</pagenumber><intpage>"+intpage+"</intpage></root>";
  1273. } catch (Exception e){
  1274. strX=e.getMessage();
  1275. }
  1276. return strX;
  1277. }
  1279. }