对数据库的操作,在Insert的同时获取到Id,保证原子性操作。而不是,先取Id,然后再插入到数据库等操作。
Oracle:
使用Oracle自带的 Returning into 语句,具体代码示例如下:
sql = @"INSERT INTO KEYWORD(KEYWORD_ID,SITE_ID,KEYWORD_NAME,STATUS,SOURCE,CREATE_TIME,LAST_CHANGED)
VALUES
(
KEYWORD_SEQ.nextVal,
:SITE_ID,
:NAME,
1,
:Source,
SYSDATE,
SYSDATE+0.0007
) RETURNING KEYWORD_ID into :Key_ID"; com.CommandText = sql;
//com.Parameters.Add(new OracleParameter(":ID", OracleDbType.Int64, allKeyWords.Select(n => n.Keyword_Id).ToArray(), ParameterDirection.Input));
com.Parameters.Add(new OracleParameter(":SITE_ID", OracleDbType.Int64, allKeyWords.Select(n => n.Site_Id).ToArray(), ParameterDirection.Input));
com.Parameters.Add(new OracleParameter(":NAME", OracleDbType.NVarchar2, allKeyWords.Select(n => n.Keyword_Name).ToArray(), ParameterDirection.Input));
com.Parameters.Add(new OracleParameter(":Source", OracleDbType.NVarchar2, allKeyWords.Select(n => n.Source).ToArray(), ParameterDirection.Input));
var outputIdParm = new OracleParameter(":Key_ID", OracleDbType.Int32, ParameterDirection.Output);
com.Parameters.Add(outputIdParm); com.ExecuteNonQuery(); var allKeyWordIds = outputIdParm.Value as OracleDecimal[];
请注意上面代码中的 Returning 语句,以及最后参数的outPut。
SqlServer:使用SqlServer自带的 @@IDENTITY 关键字,具体代码示例如下:
var cmd = dbMenloFramework.CreateCommand("insert into syslog (Thread) values('test') SELECT @@IDENTITY AS Id");
using(var read = dbMenloFramework.ExecuteDataReader(cmd)){
read.Read();
Console.WriteLine(read[].ToString());
}
MySql:
暂时缺少,如有网友有可靠的方法,请在评论中联系我。