下面的函數拋出System.InvalidOperationException
:OracleCommand.Executenonquery拋出「System.InvalidOperationException」
internal void executeNonQuery(string connectionString, OracleCommand cmd)
{
using (OracleConnection conn = new OracleConnection(connectionString))
{
using (cmd)
{
conn.Open();
cmd.ExecuteNonQuery(); //here is the error
conn.Close();
}
}
}
的附加信息是:
操作無效由於對象的當前狀態。
我嘗試在表格中插入一行。有沒有另外一種方法來解決這個錯誤?
編輯: 我建立以下方法在binaryManager類查詢:
internal object[] binaryInsert(string tblName, string tblQuery, int conStrgID, int cq)
{
object[] retValues = new object[3];
Stream myStream = null ;
OracleConnection con = null;
string conString = qm.getConnectionString("ConnectionStringToMyDB"); //is correct
byte[] data = GetBytes(tblQuery);
String sql = "INSERT INTO MYTABLES VALUES (NULL, '" + tblName + "', ':tblQueryBlob', " + conStrgID + ", " + cq + ")";
OracleCommand cmd = new OracleCommand();
cmd.CommandText = sql; // Set the sql-command
cmd.Connection = con; //con is an OracleConnection
OracleParameter param = cmd.Parameters.Add("tblQueryBlob", OracleDbType.Blob); //Add the parameter for the blobcolumn
param.Direction = ParameterDirection.Input;
param.Value = data; //Asign the Byte Array to the parameter
//command containts the parameter :tblQueryBlob with its value
retValues[0] = cmd;
retValues[1] = conString;
return retValues;
}
private byte[] GetBytes(string str)
{
byte[] bytes = new byte[str.Length * sizeof(char)];
System.Buffer.BlockCopy(str.ToCharArray(), 0, bytes, 0, bytes.Length);
return bytes;
}
我從另一個調用類的binaryInsert方法用下面的代碼:
BinaryManager bm = new bBinaryManager();
string sqlQuery = "large string with 5100 characters";
object[] binaryValues = bm.binaryInsert("TextTbl", sqlQuery, 1, 1);
string conString = binaryValues[1].ToString();
OracleCommand cmd = (OracleCommand)binaryValues[0];
QueryManager qm = new QueryManager();
qm.executeNonQuery(conString, cmd);
EDIT2(ExecuteReader):
int csID = 1;
using (OracleConnection conn = new OracleConnection(conString))
{
using (OracleCommand myCommand = new OracleCommand(query, conn))
{
conn.Open();
myCommand.Connection = conn; // FIX!
using(OracleDataReader read = myCommand.ExecuteReader())
{
if (read.HasRows)
{
while (read.Read())
{
if (read[0] == System.DBNull.Value)
{
TableObject tableDBNull = new TableObject(csID, Convert.ToString(read[1]), (byte[])read[2], Convert.ToInt32(read[3]), Convert.ToInt32(read[4]));
allTables.Add(tableDBNull);
csID++;
}
else
{
TableObject tableDBNNull = new TableObject(Convert.ToInt32(read[0]), Convert.ToString(read[1]), (byte[])read[2], Convert.ToInt32(read[3]), Convert.ToInt32(read[4]));
allTables.Add(tableDBNNull);
}
}
}
}
conn.Close();
}
錯誤發生在if塊:if (read[0] == System.DBNull.Value)
你能提供查詢嗎? –
@ArtemKulikov發佈更新 – Hack4Life