SqlCopy.cs

public class SqlCopy : IDisposable
    {
        private DbConnection originConnection;
        private DbConnection destinationConnection;
        private ISqlQueryGeneration queryGenerator;
        private List<ReferentialConstraintAssociation> constraintAssociation;
        public SqlCopy(ISqlQueryGeneration generator, DbConnection origin, DbConnection destination)
        {
            if (origin == null)
            {
                throw new ArgumentNullException("Origin connection should not be null.");
            }
            if (destination == null)
            {
                throw new ArgumentNullException("Destination connection should not be null.");
            }
            constraintAssociation = new List<ReferentialConstraintAssociation>();
            queryGenerator = generator;
            originConnection = origin;
            destinationConnection = destination;
        }
        public void CopyData<T>()
        {
            var columns= ColumnsGetter.GetColumns(typeof(T));
            var tableName = typeof(T).Name;
            var selectQuery = queryGenerator.GetSelectQuery(columns,tableName);
            var insertQuery = queryGenerator.GetInsertQuery(ColumnsGetter.ExcludeId(columns), tableName, true);
            var selectResult = originConnection.Query<T>(selectQuery);
            var constraint = new ReferentialConstraintAssociation();
            constraint.ForeignKeyNames.Add(string.Format("{0}Id", tableName));
            foreach (var item in selectResult)
            {
                var itemForInsert = ReplaceConstraints(item);
                var newId = destinationConnection.ExecuteScalar<int>(insertQuery, itemForInsert);
                constraint.MatchingReferenceDictionary.Add(GetIdValue(item), newId);
            }
            constraintAssociation.Add(constraint);
        }
        public void Dispose()
        {
            originConnection.Dispose();
            destinationConnection.Dispose();
        }
        private int GetIdValue<T>(T item)
        {
            var property = item.GetType().GetProperty("Id");
            if (property!=null)
            {
                return Convert.ToInt32(property.GetValue(item, null));
            }
            return -1;
        }
        private T ReplaceConstraints<T>(T item) {
            var properties = item.GetType().GetProperties();
            foreach (var constraint in constraintAssociation)
            {
                foreach (var constraintName in constraint.ForeignKeyNames)
                {
                    var property = properties.FirstOrDefault(prop => prop.Name.Equals(constraintName, StringComparison.InvariantCultureIgnoreCase));
                    if (property!=null){
                        var newValue = constraint.MatchingReferenceDictionary.FirstOrDefault(key=>key.Key.Equals(property.GetValue(item,null)));
                        property.SetValue(item,newValue.Value,null);
                    }
                }
            }
            return item;
        }
        
    }