ServiceStack.OrmLite 筆記2
這篇主要介紹 增加
db.Insert(new Employee { Id = 1, Name = "Employee 1" }); //預設同步
await db.InsertAsync(new Employee { Id = 1, Name = "Employee 1" }); //異步 其他的異步類似這裡的這個示例
db.InsertOnly(new Person { FirstName = "Amy" }, q => q.Insert(p => new {p.FirstName}))
// 插入部分字段 後面的參數q.Insert表示要插入的字段 生成sql: INSERT INTO "Person" ("FirstName") VALUES ('Amy')
var rowId = db.Insert(new Poco { Text = "Text" }, selectIdentity:true);// selectIdentity:true傳回自增長的id
這裡代碼有點多 全局的插入時過濾 類似的有UpdateFilter ,感覺就是插入時對資料進行攔截,可以發揮你的想象,比如可以在這裡加日志,或者擴充新的字段,做愛做的事情。
public interface IAudit
{
DateTime CreatedDate { get; set; }
DateTime ModifiedDate { get; set; }
string ModifiedBy { get; set; }
}
//表對應的類
public class AuditTableA : IAudit
public AuditTableA()
this.CreatedDate = this.ModifiedDate = DateTime.UtcNow;
[AutoIncrement]
public int Id { get; set; }
public DateTime CreatedDate { get; set; }
public DateTime ModifiedDate { get; set; }
public string ModifiedBy { get; set; }
}
OrmLiteConfig.InsertFilter = (dbCmd, row) => {
var auditRow = row as IAudit;
if (auditRow != null)
auditRow.CreatedDate = auditRow.ModifiedDate = DateTime.UtcNow;
};
下面是上面方法的新體位,也來自官網。對資料進行驗證
OrmLiteConfig.InsertFilter = OrmLiteConfig.UpdateFilter = (dbCmd, row) => {
if (auditRow != null && auditRow.ModifiedBy == null)
throw new ArgumentNullException("ModifiedBy");
try
db.Insert(new AuditTable());
catch (ArgumentNullException) {
//throws ArgumentNullException
db.Insert(new AuditTable { ModifiedBy = "Me!" }); //succeeds
下面的代碼因為也有insert 就也放上吧
在表被建立或者删除的時候執行sql語句
[PostCreateTable("INSERT INTO TableWithSeedData (Name) VALUES ('Foo');" +
"INSERT INTO TableWithSeedData (Name) VALUES ('Bar');")]
public class TableWithSeedData
[AutoIncrement]
public int Id { get; set; }
public string Name { get; set; }
或
typeof(TableWithSeedData)
.AddAttributes(new PostCreateTableAttribute(
"INSERT INTO TableWithSeedData (Name) VALUES ('Foo');" +
"INSERT INTO TableWithSeedData (Name) VALUES ('Bar');"));
前戲和事後,都是可以有自己的玩法
[PreCreateTable(runSqlBeforeTableCreated)]
[PostCreateTable(runSqlAfterTableCreated)]
[PreDropTable(runSqlBeforeTableDropped)]
[PostDropTable(runSqlAfterTableDropped)]
public class Table {}
Db.ExecuteSql("INSERT INTO page_stats (ref_id, fav_count) VALUES (@refId, @favCount)", new { refId, favCount }) //直接執行sql語句
Db.ExecuteSqlAsync("UPDATE page_stats SET view_count = view_count + 1 WHERE id = @id", new { id })//直接執行sql語句
作者:
過錯出處:http://www.cnblogs.com/wang2650/
關于作者:net開發做的久而已。十餘年時光虛度!
本文版權歸作者和部落格園共有,歡迎轉載,但未經作者同意必須保留此段聲明,且在文章頁面明顯位置給出原文連接配接。如有問題,可以郵件:[email protected]
聯系我,非常感謝。