--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/Source/Mapping/TextDataWriter.cs	Thu Mar 27 21:46:09 2014 +0400
@@ -0,0 +1,194 @@
+using System;
+using System.IO;
+using System.Text;
+
+using BLToolkit.Reflection;
+
+namespace BLToolkit.Mapping
+{
+	public class TextDataWriter : ISupportMapping
+	{
+		#region Constructors
+
+		public TextDataWriter(Stream stream, params string[] fieldNames)
+			: this(stream, Map.DefaultSchema, fieldNames)
+		{
+		}
+
+		public TextDataWriter(Stream stream, Type type)
+			: this(stream, Map.DefaultSchema, Map.GetObjectMapper(type).FieldNames)
+		{
+		}
+
+		public TextDataWriter(Stream stream, MappingSchema mappingSchema, params string[] fieldNames)
+			: this(new StreamWriter(stream), mappingSchema, fieldNames)
+		{
+		}
+
+		public TextDataWriter(Stream stream, MappingSchema mappingSchema, Type type)
+			: this(stream, mappingSchema, mappingSchema.GetObjectMapper(type).FieldNames)
+		{
+		}
+
+		public TextDataWriter(TextWriter writer, params string[] fieldNames)
+			: this(writer, Map.DefaultSchema, fieldNames)
+		{
+		}
+
+		public TextDataWriter(TextWriter writer, Type type)
+			: this(writer, Map.DefaultSchema, Map.GetObjectMapper(type).FieldNames)
+		{
+		}
+
+		public TextDataWriter(TextWriter writer, MappingSchema mappingSchema, params string[] fieldNames)
+		{
+			GC.SuppressFinalize(this);
+
+			if (mappingSchema == null) throw new ArgumentNullException("mappingSchema");
+
+			_writer        = writer;
+			_names         = fieldNames;
+
+			_values = new string[_names.Length];
+
+			WriteHeader();
+		}
+
+		public TextDataWriter(TextWriter writer, MappingSchema mappingSchema, Type type)
+			: this(writer, mappingSchema, mappingSchema.GetObjectMapper(type).FieldNames)
+		{
+		}
+
+		#endregion
+
+		#region Public Members
+
+		public virtual void WriteEnd()
+		{
+			_writer.WriteLine("*-");
+			_writer.Flush();
+		}
+
+		public virtual Type GetFieldType(int index)
+		{
+			return typeof(string);
+		}
+
+		public virtual int GetOrdinal(string name)
+		{
+			for (int i = 0; i < _names.Length; i++)
+				if (_names[i] == name)
+					return i;
+
+			return 0;
+		}
+
+		public virtual void SetValue(int index, object value)
+		{
+			_values[index] = value == null? null: value.ToString();
+		}
+
+		public virtual void SetValue(string name, object value)
+		{
+			SetValue(GetOrdinal(name), value);
+		}
+
+		#endregion
+
+		#region Protected Members
+
+		private readonly TextWriter    _writer;
+		private readonly string[]      _names;
+		private readonly string[]      _values;
+
+		private void WriteHeader()
+		{
+			_writer.Write("*");
+
+			foreach (string name in _names)
+			{
+				_writer.Write(':');
+				_writer.Write(name);
+			}
+
+			_writer.WriteLine();
+		}
+
+		private void WriteRecord()
+		{
+			_writer.Write("**");
+
+			char[] delimiters = new char[] { ',', ':', '|', '-', '_' };
+			char   delimiter  = '\0';
+
+			foreach (char ch in delimiters)
+			{
+				bool found = false;
+
+				foreach (string value in _values)
+				{
+					if (value != null && value.IndexOf(ch) >= 0)
+					{
+						found = true;
+						break;
+					}
+				}
+
+				if (!found)
+				{
+					delimiter = ch;
+					break;
+				}
+			}
+
+			if (delimiter == 0)
+				delimiter = delimiters[0];
+
+			char[] exChars = new char[] { delimiter, '\r', '\n', '\t', '\0' };
+
+			foreach (string value in _values)
+			{
+				_writer.Write(delimiter);
+
+				if (value != null)
+				{
+					if (value.Length == 0)
+						_writer.Write('*');
+					else
+					{
+						if (value.IndexOfAny(exChars) >= 0)
+						{
+							_writer.Write('+');
+							_writer.Write(Convert.ToBase64String(Encoding.Unicode.GetBytes(value)));
+						}
+						else
+						{
+							if (value[0] == '*' || value[0] == '+')
+								_writer.Write('*');
+
+							_writer.Write(value);
+						}
+					}
+				}
+			}
+
+			_writer.WriteLine();
+			_writer.Flush();
+		}
+
+		#endregion
+
+		#region ISupportMapping Members
+
+		void ISupportMapping.BeginMapping(InitContext initContext)
+		{
+		}
+
+		void ISupportMapping.EndMapping(InitContext initContext)
+		{
+			WriteRecord();
+		}
+
+		#endregion
+	}
+}