1 public IList<ACCP_RAIN> QueryAll(string beginTime, string endTime, string type) 2 { 3 beginTime = "2012-1-1"; endTime = "2014-10-10"; type = "ZQ"; 4 List<ACCP_RAIN> list = new List<ACCP_RAIN>(); 5 DbDataReader reader = null; 6 7 try 8 { 9 OracleParameter[] paras = new OracleParameter[4]; 10 OracleParameter para1 = new OracleParameter("ptm1", OracleType.VarChar); 11 para1.Value = beginTime; 12 OracleParameter para2 = new OracleParameter("ptm2", OracleType.VarChar); 13 para2.Value = endTime; 14 OracleParameter para3 = new OracleParameter("retp", OracleType.VarChar); 15 para3.Value = type; 16 OracleParameter para4 = new OracleParameter("p_cur", OracleType.Cursor); 17 para4.Direction = ParameterDirection.Output; 18 paras[0] = para1; 19 paras[1] = para2; 20 paras[2] = para3; 21 paras[3] = para4; 22 23 DbConnection conn = DbFactory.GetDbCon(); 24 conn.Open(); 25 DbTransaction trans = conn.BeginTransaction(); 26 reader = (DbHelper as OracleHelper).ExecuteReader(conn, trans, CommandType.StoredProcedure, "GETDRP.PROC_GETDRP", paras); 27 while (reader.Read()) 28 { 29 list.Add(SqlDataToEntity.ToEntity<ACCP_RAIN>(reader)); 30 } 31 trans.Dispose(); 32 conn.Close(); 33 conn.Dispose(); 34 } 35 catch (Exception ex) 36 { 37 return null; 38 } 39 finally 40 { 41 if (reader != null) reader.Close(); 42 } 43 return list; 44 }
相关文章: