Source/Providers/NFX.MySQL/MySQLDataStore.cs
/// <summary>
/// Performs CRUD batch save. Override to do custom batch saving
/// </summary>
Performs CRUD batch save. Override to do custom batch saving
Performs CRUD batch save . Override to do custom batch saving
protected internal virtual int DoSave(MySqlConnection cnn, MySqlTransaction transaction, RowsetBase[] rowsets)
        {
            if (rowsets==null) return 0;
            var affected = 0;
            foreach(var rset in rowsets)
            {
                foreach(var change in rset.Changes)
                {
                    switch(change.ChangeType)
                    {
                        case RowChangeType.Insert: affected += DoInsert(cnn, transaction, change.Row); break;
                        case RowChangeType.Update: affected += DoUpdate(cnn, transaction, change.Row, change.Key); break;
                        case RowChangeType.Upsert: affected += DoUpsert(cnn, transaction, change.Row); break;
                        case RowChangeType.Delete: affected += DoDelete(cnn, transaction, change.Row, change.Key); break;
                    }
                }
            }
            return affected;
        }
protected internal virtual int DoSave ( MySqlConnection cnn , MySqlTransaction transaction , RowsetBase [ ] rowsets ) { if ( rowsets == null ) return 0 ; var affected = 0 ; foreach ( var rset in rowsets ) { foreach ( var change in rset . Changes ) { switch ( change . ChangeType ) { case RowChangeType . Insert : affected += DoInsert ( cnn , transaction , change . Row ) ; break ; case RowChangeType . Update : affected += DoUpdate ( cnn , transaction , change . Row , change . Key ) ; break ; case RowChangeType . Upsert : affected += DoUpsert ( cnn , transaction , change . Row ) ; break ; case RowChangeType . Delete : affected += DoDelete ( cnn , transaction , change . Row , change . Key ) ; break ; } } } return affected ; }
Performs CRUD batch save.
Performs CRUD batch save .
cnn
MySqlConnection
transaction
MySqlTransaction
rowsets
RowsetBase[]