Npgsql datatable serializer

gistfile1.cs

private void serializeDataTable(NpgsqlCopySerializer serializer, DataTable datatable, string[] columnNamesInFixedOrder)
{
	var serializeRow = new List<Action<DataRow>>();

	var serializeByType = new Dictionary<Type, Action<object>>();
	serializeByType[typeof (bool)] = (o => { if (o == null) serializer.AddNull(); else serializer.AddBool((bool)o); });
	serializeByType[typeof (string)] = (o => { if (o == null) serializer.AddNull(); else serializer.AddString((string)o); });
	serializeByType[typeof (DateTime)] = (o => { if (o == null) serializer.AddNull(); else serializer.AddDateTime((DateTime)o); });
	serializeByType[typeof(byte)] = (o => { if (o == null) serializer.AddNull(); else serializer.AddInt32((byte)o); });
	serializeByType[typeof (int)] = (o => { if (o == null) serializer.AddNull(); else serializer.AddInt32((int)o); });
	serializeByType[typeof (long)] = (o => { if (o == null) serializer.AddNull(); else serializer.AddInt64((long)o); });
	serializeByType[typeof (double)] = (o => { if (o == null) serializer.AddNull(); else serializer.AddNumber((double)o); });
	serializeByType[typeof (decimal)] = (o => { if (o == null) serializer.AddNull(); else serializer.AddNumber((double)(decimal)o); });
	serializeByType[typeof (float)] = (o => { if (o == null) serializer.AddNull(); else serializer.AddNumber((double)(float)o); });

	foreach (var column in columnNamesInFixedOrder)
	{
		var c = column;
		var type = datatable.Columns[c].DataType;
		serializeRow.Add(row => serializeByType[type](row.IsNull(c) ? null : row[c]));
	}

	foreach (DataRow row in datatable.Rows)
	{
		serializeRow.ForEach(action => action(row));
		serializer.EndRow();
		serializer.Flush();
	}
}