急用，请大家帮忙把这段代码改写成db2的存储过程

echo_huang

由于这段代码查询时间过长，因此，希望能将它改写成sp,但小妹我没写过，希望高手指点一二，最好能写个完整的范例出来，感激不尽！！！

1. 
   
2.         public boolean setConn(String CUSTNO,String Qdate)
   
3.         {
   
4. //                int totalRows=1;
   
5.                 int greatUnit=0;
   
6.                 int smallUnit=0;       
   
7.                 int nm_ly3204=0,nm_ly3205=0,nm_ly3206=0,nm_ly3211=0,nm_ly3208=0;       
   
8.                 int ax_ly3204=0,ax_ly3205=0,ax_ly3206=0,ax_ly3211=0,ax_ly3208=0;
   
9.                 String sql2="";
   
10.                 String sql3="";
    
11.                
    
12.                 ResultSet rs;
    
13.                 ResultSet rs2;
    
14.                 ResultSet rs3;
    
15.                
    
16.                 String ly1105="";//名称
    
17.                 String ly3202="";
    
18.                 String ly3203="";
    
19.                 String ly1146="";
    
20.                 int ly3201=0;       
    
21.                 int ly3204=0;
    
22.                 int ly3205=0;
    
23.                 int ly3206=0;
    
24.                 int ly3211=0;
    
25.                 int ly3208=0;
    
26.                 int sum_ly3205=0,sum_ly3206=0;
    
27.                 int goodsRate=0;//转换率
    
28.                 float ly3211_b=0.00f,nm_ly3211_b=0.00f,ax_ly3211_b=0.00f;
    
29.                 String rowLine;               
    
30.                 String fromdate;
    
31.                 fromdate=Qdate.substring(0,6);
    
32.                 fromdate=fromdate+"01";               
    
33.                 String flag="";
    
34.                 try
    
35.                 {
    
36.                         db1=new getFromPool();
    
37.                         if(!db1.isRight)
    
38.                         {
    
39.                           db1.restartConn();
    
40.                         }                                       
    
41.                         if(!db1.isRight)
    
42.                         {
    
43.                           db1=new getFromPool(1);
    
44.                         }
    
45. 
    
46.                         db2=new getFromPool();
    
47.                         if(!db2.isRight)
    
48.                         {
    
49.                           db2.restartConn();
    
50.                         }                                       
    
51.                         if(!db2.isRight)
    
52.                         {
    
53.                           db2=new getFromPool(1);
    
54.                         }
    
55.                         Statement stmt = db1.getStatement();
    
56.                         Statement stmt2 = db2.getStatement();
    
57.                         String sql="select distinct ly3203 from LYPLIBS.lyf32 a inner join LYPLIBS.lyf11 b on a.ly3230=b.ly1120 and a.ly3212=b.ly1132 and a.ly3203=b.ly1101 where ly3230='"+CUSTNO+"' and ly3201="+Qdate+" and ly3212='"+DcNo+"'";
    
58.                         System.out.println(sql);
    
59.                         boolean isRS = stmt.execute(sql);       
    
60.                         if (isRS)
    
61.                         {
    
62.                                 rs=stmt.getResultSet();
    
63.                                 while(rs.next())
    
64.                                 {               
    
65.                                         ly3203=rs.getString(1);
    
66.                                        
    
67.                                         //求共同资料
    
68.                                         sql2="select ly1105,ly1146,ly1112 from LYPLIBS.lyf11 where ly1101='"+ly3203+"' and ly1120='"+CUSTNO+"'";
    
69.                                         System.out.println(sql2);
    
70.                                         rs2=stmt2.executeQuery(sql2);
    
71.                                         if(rs2.next())
    
72.                                         {
    
73.                                         ly1105=rs2.getString(1);
    
74.                                         ly1146=rs2.getString(2);
    
75.                                         goodsRate=rs2.getInt(3);               
    
76.                                         }
    
77.                                         rs2.close();
    
78.                                        
    
79.                                         //求A品数量
    
80.                                         sql2="select ly3201,ly3204,ly3205,ly3206,ly3211,ly3208 from LYPLIBS.lyf32 where ly3230='"+CUSTNO+"' and ly3201="+Qdate+" and ly3203='"+ly3203+"' and ly3202='NM'";
    
81.                                         System.out.println(sql2);
    
82.                                         rs2=stmt2.executeQuery(sql2);
    
83.                                         if (rs2.next())
    
84.                                         {
    
85.                                                 ly3201=rs2.getInt(1);
    
86.                                                 nm_ly3204=rs2.getInt(2);                                               
    
87.                                                 nm_ly3205=rs2.getInt(3);
    
88.                                                 nm_ly3206=rs2.getInt(4);
    
89.                                                 nm_ly3211=rs2.getInt(5);
    
90.                                                 nm_ly3208=rs2.getInt(6);                                               
    
91.                                         }
    
92.                                         else
    
93.                                         {
    
94.                                                 nm_ly3204=0;
    
95.                                                 nm_ly3205=0;
    
96.                                                 nm_ly3206=0;
    
97.                                                 nm_ly3211=0;
    
98.                                                 nm_ly3208=0;
    
99.                                         }
    
100.                                         rs2.close();
     
101.                                        
     
102.                                         //求B品数量
     
103.                                         sql2="select ly3201,ly3204,ly3205,ly3206,ly3211,ly3208 from LYPLIBS.lyf32 where ly3230='"+CUSTNO+"' and ly3201="+Qdate+" and ly3203='"+ly3203+"' and ly3202='AX'";
     
104.                                         System.out.println(sql2);                                       
     
105.                                         rs2=stmt2.executeQuery(sql2);
     
106.                                         if (rs2.next())
     
107.                                         {
     
108.                                                 ly3201=rs2.getInt(1);
     
109.                                                 ax_ly3204=rs2.getInt("ly3204");
     
110.                                                 ax_ly3205=rs2.getInt("ly3205");
     
111.                                                 ax_ly3206=rs2.getInt("ly3206");
     
112.                                                 ax_ly3211=rs2.getInt("ly3211");
     
113.                                                 ax_ly3208=rs2.getInt("ly3208");
     
114.                                         }
     
115.                                         else
     
116.                                         {
     
117.                                                 ax_ly3204=0;
     
118.                                                 ax_ly3205=0;
     
119.                                                 ax_ly3206=0;
     
120.                                                 ax_ly3211=0;
     
121.                                                 ax_ly3208=0;
     
122.                                         }
     
123.                                         rs2.close();                                       
     
124.                                         sql2=null;
     
125.                                
     
126.                                         ly3204=nm_ly3204+ax_ly3204;
     
127.                                         ly3205=nm_ly3205+ax_ly3205;                                       
     
128.                                         ly3206=nm_ly3206+ax_ly3206;
     
129.                                         ly3211=nm_ly3211+ax_ly3211;
     
130.                                         ly3208=nm_ly3208+ax_ly3208;
     
131.                                        
     
132.                                         if (goodsRate==0)
     
133.                                         {
     
134.                                         ly3211_b=0;       
     
135.                                         nm_ly3211_b=0;
     
136.                                         ax_ly3211_b=0;
     
137.                                         flag="单位转换运算出错，请修改";
     
138.                                         System.out.println(flag);
     
139.                                         }
     
140.                                         else
     
141.                                         {
     
142.                                         ly3211_b=ly3211/goodsRate;       
     
143.                                         nm_ly3211_b=nm_ly3211/goodsRate;
     
144.                                         ax_ly3211_b=ax_ly3211/goodsRate;
     
145.                                         }
     
146.                                         total5+=ly3204;
     
147.                                         total6+=ly3205;
     
148.                                         total7+=ly3206;
     
149.                                         total8+=ly3211;
     
150.                                         total16+=ly3208;
     
151.                                         total9+=ly3211_b;
     
152.                                         total10+=nm_ly3211_b;
     
153.                                         total11+=nm_ly3211;
     
154.                                         total12+=ax_ly3211_b;
     
155.                                         total13+=ax_ly3211;       
     
156.        
     
157.                                        
     
158.                                         writeFile.writeCell(0,totalRows,ly3201,null);
     
159.                                            writeFile.writeCell(1,totalRows,-0,ly3203);
     
160.                                         writeFile.writeCell(2,totalRows,-0,ly1105);
     
161.                                         writeFile.writeCell(3,totalRows,-0,ly1146);
     
162.                                     writeFile.writeCell(4,totalRows,goodsRate,null);
     
163.                                         writeFile.writeCell(5,totalRows,ly3204,null);
     
164.                                     writeFile.writeCell(6,totalRows,ly3205,null);
     
165.                                         writeFile.writeCell(7,totalRows,ly3206,null);
     
166.                                 writeFile.writeCell(8,totalRows,ly3211,null);
     
167.                                 writeFile.writeCell2(9,totalRows,ly3211_b,null);
     
168.                                 writeFile.writeCell2(10,totalRows,nm_ly3211_b,null);
     
169.                                         writeFile.writeCell(11,totalRows,nm_ly3211,null);
     
170.                                 writeFile.writeCell2(12,totalRows,ax_ly3211_b,null);                                         
     
171.                                         writeFile.writeCell(13,totalRows,ax_ly3211,null);                                        
     
172.                                         writeFile.writeCell(14,totalRows,ly3208,null);  
     
173.                                 sql2="select sum(ly3205),sum(ly3206) from LYPLIBS.LYF32 where ly3230='"+CUSTNO+"' and ly3201>;="+fromdate+" and ly3201<="+Qdate+" and ly3203='"+ly3203+"'";
     
174.                                 System.out.println(sql2);                               
     
175.                                 rs2=stmt2.executeQuery(sql2);
     
176.                                 if(rs2.next())
     
177.                                 {
     
178.                                         sum_ly3205=rs2.getInt(1);
     
179.                                         sum_ly3206=rs2.getInt(2);
     
180.                                 writeFile.writeCell(15,totalRows,sum_ly3205,null);                                         
     
181.                                         writeFile.writeCell(16,totalRows,sum_ly3206,null);           
     
182.                                 }
     
183.                                 rs2.close();
     
184.                                 sql2="";
     
185.                                 total14+=sum_ly3205;
     
186.                                 total15+=sum_ly3206;
     
187.                                 totalRows++;       
     
188.                         }                               
     
189.                                 rs.close();                               
     
190.                                 stmt2.close();       
     
191.                                 }
     
192.                                 else
     
193.                                 {
     
194.                                         System.out.println("当时无相关记录");
     
195.                                 }
     
196.                                 stmt.close();       
     
197.                 }
     
198.                 catch(Exception e)
     
199.                 {
     
200.                         e.printStackTrace();
     
201.                         errorMsg="数据查询出错";
     
202.                         return false;
     
203.                 }
     
204.                 finally
     
205.                 {
     
206.                         try
     
207.                         {
     
208.                                 db1.getConnection().close();
     
209.                                 db2.getConnection().close();
     
210.                         }catch(Exception dd){
     
211.                                 dd.printStackTrace();
     
212.                         }
     
213.                
     
214.                 }
     
215.                 return true;
     
216.                
     
217. }
     
218. 
     
219. 
     

复制代码

Law

呵呵，，java我不会啊，我只会c的sp，呵呵

echo_huang

我也没有写过。
只是大概有个概念应该可以实现。
这周打算去借本db2/400的书看看。网上好像很少db2存储过程的入门书籍。

不过现在急需这个存储过程，有经验的高手们请帮忙呀。

javacool

呵呵 其实你使用DB2自带的存储过程开发器 他会自动帮你生成主框架
非数据库操作不用变的 只要把数据库连接改一下就行了
如果正确的话 选择构建选项 就可以自动生成SP for java 了，编译 注册全帮你搞定