using System; using System.Collections.Generic; using System.Linq; using System.Text; using FLocal.Core.DB; namespace FLocal.Common.actions { public class InsertChange : AbstractChange { private int? id; private Dictionary data; public InsertChange(ISqlObjectTableSpec tableSpec, Dictionary data) : base(tableSpec, from kvp in data select kvp.Value) { this.id = null; this.data = data; } public override int? getId() { return this.id; } public override void Lock(Transaction transaction) { Config.instance.mainConnection.lockTable(transaction, this.tableSpec); } protected override void doApply(Transaction transaction) { Dictionary processedData = new Dictionary(); foreach(KeyValuePair kvp in this.data) { processedData[kvp.Key] = kvp.Value.getStringRepresentation(); } this.id = int.Parse(Config.instance.mainConnection.insert( transaction, this.tableSpec, processedData )); } } }