2013-04-25 77 views
2

我的问题与this one类似,我如何使用OracleDataReader检索给定记录的所有字段?目前,我一直在使用这种方法,它一次只返回一个列值:如何使用OracleDataReader检索给定记录的所有字段?

public string Select_File(string filename, string subdirectory, string envID) 
{ 
    Data_Access da = new Data_Access(); 
    OracleConnection conn = da.openDB(); 

    OracleCommand cmd = new OracleCommand(); 
    cmd.Connection = conn; 
    cmd.CommandText = "SELECT * FROM EIP_Deployment_Files" 
     + " WHERE Filename ='" + filename + "'" 
     + " AND Subdirectory = '" + subdirectory + "'" 
     + " AND Environment_ID = '" + envID + "'"; 
    cmd.CommandType = CommandType.Text; 

    string x; 
    OracleDataReader dr = cmd.ExecuteReader(); 
    if (dr.HasRows) // file exists in DB 
    { 
     dr.Read(); 
     x = dr.GetString(2).ToString(); // return baseline filename (index 2) 
    } 
    else 
    { 
     x = "New File"; 
    } 

    cmd.Dispose(); 
    da.CloseDB(conn); 
    return x; 
} 

我敢肯定,这种方法是远远不够完善和PPL会很快指出这一点(我是基本上是由我的主管给出的,因为我之前没有任何ASP.NET的经验),但我真正关心的是它的工作原理。我的问题是:如何修改以返回全部给定记录的字段?

这些字段将是VARCHAR2,CHAR或DATE数据类型(如果这有所不同),并且其中某些值可能为空。我在想我可以将它们转换为字符串并将它们作为列表返回?

+0

注意:'cmd.CommandText'容易受到注入攻击 – rdev5 2016-06-16 23:58:53

回答

6

要从DataReader中的当前行的列中读取所有数据,可以简单地使用GetValues(),并从数组中提取值 - 它们将是数据库类型的对象。

Object[] values; 
int numColumns = dr.GetValues(values); //after "reading" a row 
for (int i = 0; i < numColumns; i++) { 
    //read values[i] 
} 

MSDN - “对于大多数应用,GetValues方法提供了一种用于检索所有列,而不是分别检索各列的有效手段。”

+0

对不起,我很困惑。 GetValues()是否为记录的每个字段检索实际值? – user1985189 2013-04-25 19:15:54

+0

是的。它填充传入的对象数组,同时返回列数作为返回值。这里有一个指向它的文档的链接:http://msdn.microsoft.com/en-us/library/system.data.oracleclient.oracledatareader.getvalues.aspx – Jasmine 2013-04-25 19:17:52

+0

好的谢谢然后在'//读取值[我]'部分? – user1985189 2013-04-25 19:21:27

6

如果u想是这样的:

List<User> lstUser = new List<User>(); 
      string sqlQuery = "Select * from User_T where User_Name='" + oUser.UserName + "' And Password='" +oUser.Password + "' AND IsActive='"+1+"' AND IsDelete='"+0+"'"; 
      string connectionString = "Data Source=ORCL;User Id=ACCOUNTS;Password=ACCOUNTS"; 
      using (DBManager dbManager = new DBManager(connectionString)) 
      { 
       try 
       { 

        dbManager.Open(); 
        OracleDataReader dataReader = dbManager.ExecuteDataReader(sqlQuery); 
        while (dataReader.Read()) 
        { 
         oUser = new User(); 
         oUser.Id = Convert.ToInt32(dataReader["ID"]); 
         oUser.CompanyId = Convert.ToInt32(dataReader["Company_ID"]); 
         oUser.BranchId = Convert.ToInt32(dataReader["Branch_ID"]); 
         oUser.UserName = Convert.ToString(dataReader["User_Name"]); 
         lstUser.Add(oUser); 
        } 
        dataReader.Close(); 
        dataReader.Dispose(); 

       } 
       catch 
       (Exception) 
       { 


       } 
       finally 
       { 
        dbManager.Close(); 
        dbManager.Dispose(); 
       } 
+0

嗯,也许!我将不得不考虑它tmw,但感谢您的回答 – user1985189 2013-04-25 20:29:58

+1

这是阅读每列*的名称*这是不完全相同的事情阅读所有的列,不管他们的名字是什么。 – Jasmine 2013-04-25 22:03:01

+1

注意:'sqlQuery'容易受到注入攻击 – rdev5 2016-06-16 23:58:23

0

对不起张贴的答案,一个很老的问题。由于没有一个答案是正确的(他们有安全问题或不检查DBNull),我决定发布我自己的。

public async Task<StringBuilder> FetchFileDetailsAsync(string filename, string subdirectory, string envId) 
    { 
     var sb = new StringBuilder(); 
     //TODO: Check the parameters 

     const string connectionString = "user id=userid;password=secret;data source=" + 
             "(DESCRIPTION=(ADDRESS=(PROTOCOL=tcp)(HOST=10.0.0.8)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=xe)))"; 

     const string selectQuery = "SELECT * FROM EIP_Deployment_Files" 
           + " WHERE Filename = :filename" 
           + " AND Subdirectory = :subdirectory" 
           + " AND Environment_ID = :envID" 
           + " AND rownum<=1"; 

     using (var connection = new OracleConnection(connectionString)) 
     using (var cmd = new OracleCommand(selectQuery, connection) {BindByName = true, FetchSize = 1 /*As we are expecting only one record*/}) 
     { 

      cmd.Parameters.Add(":filename", OracleDbType.Varchar2).Value = filename; 
      cmd.Parameters.Add(":subdirectory", OracleDbType.Varchar2).Value = subdirectory; 
      cmd.Parameters.Add(":envID", OracleDbType.Varchar2).Value = envId; 

      //TODO: Add Exception Handling 
      await connection.OpenAsync(); 
      var dataReader = await cmd.ExecuteReaderAsync(CommandBehavior.CloseConnection); 

      var rowValues = new object[dataReader.FieldCount]; 
      if (dataReader.Read()) 
      { 
       dataReader.GetValues(rowValues); 
       for (var keyValueCounter = 0; keyValueCounter < rowValues.Length; keyValueCounter++) 
       { 
        sb.AppendFormat("{0}:{1}", dataReader.GetName(keyValueCounter), 
         rowValues[keyValueCounter] is DBNull ? string.Empty : rowValues[keyValueCounter]) 
         .AppendLine(); 
       } 

      } 
      else 
      { 
       //No records found, do something here 
      } 
      dataReader.Close(); 
      dataReader.Dispose(); 
     } 
     return sb; 
    } 
相关问题