Add support for new types to MySqlBulkCopy. Fixes #1143

Author: bgrainger

src/MySqlConnector/MySqlBulkCopy.cs

@@ -1,5 +1,7 @@
 using System.Buffers;
 using System.Buffers.Text;
+using System.Globalization;
+using System.Numerics;
 using System.Text;
 using MySqlConnector.Core;
 using MySqlConnector.Logging;
@@ -550,6 +552,16 @@ static bool WriteValue(MySqlConnection connection, object value, ref int inputIn
 				// store as UTC as it will be read as such when deserialized from a timespan column
 				return WriteString("{0:yyyy'-'MM'-'dd' 'HH':'mm':'ss'.'ffffff}".FormatInvariant(dateTimeOffsetValue.UtcDateTime), ref utf8Encoder, output, out bytesWritten);
 			}
+#if NET6_0_OR_GREATER
+			else if (value is DateOnly dateOnlyValue)
+			{
+				return WriteString("timestamp('{0:yyyy'-'MM'-'dd}')".FormatInvariant(dateOnlyValue), ref utf8Encoder, output, out bytesWritten);
+			}
+			else if (value is TimeOnly timeOnlyValue)
+			{
+				return WriteString("time '{0:HH':'mm':'ss'.'ffffff}'".FormatInvariant(timeOnlyValue), ref utf8Encoder, output, out bytesWritten);
+			}
+#endif
 			else if (value is TimeSpan ts)
 			{
 				var isNegative = false;
@@ -594,6 +606,14 @@ static bool WriteValue(MySqlConnection connection, object value, ref int inputIn
 			{
 				return WriteString("{0:d}".FormatInvariant(value), ref utf8Encoder, output, out bytesWritten);
 			}
+			else if (value is BigInteger bigInteger)
+			{
+				return WriteString(bigInteger.ToString(CultureInfo.InvariantCulture), ref utf8Encoder, output, out bytesWritten);
+			}
+			else if (value is MySqlDecimal mySqlDecimal)
+			{
+				return WriteString(mySqlDecimal.ToString(), ref utf8Encoder, output, out bytesWritten);
+			}
 			else
 			{
 				throw new NotSupportedException("Type {0} not currently supported. Value: {1}".FormatInvariant(value.GetType().Name, value));

tests/SideBySide/BulkLoaderSync.cs

@@ -515,6 +515,50 @@ public void BulkCopyNullDataTable()
 		Assert.Throws<ArgumentNullException>(() => bulkCopy.WriteToServer(default(DataTable)));
 	}
 
+#if !BASELINE
+	[Fact]
+	public void BulkCopyDataTableWithMySqlDecimal()
+	{
+		var dataTable = new DataTable()
+		{
+			Columns =
+			{
+				new DataColumn("id", typeof(int)),
+				new DataColumn("data", typeof(MySqlDecimal)),
+			},
+			Rows =
+			{
+				new object[] { 1, new MySqlDecimal("1.234") },
+				new object[] { 2, new MySqlDecimal("2.345") },
+			},
+		};
+
+		using var connection = new MySqlConnection(GetLocalConnectionString());
+		connection.Open();
+		using (var cmd = new MySqlCommand(@"drop table if exists bulk_load_data_table;
+create table bulk_load_data_table(a int, b decimal(20, 10));", connection))
+		{
+			cmd.ExecuteNonQuery();
+		}
+
+		var bulkCopy = new MySqlBulkCopy(connection)
+		{
+			DestinationTableName = "bulk_load_data_table",
+		};
+		var result = bulkCopy.WriteToServer(dataTable);
+		Assert.Equal(2, result.RowsInserted);
+		Assert.Empty(result.Warnings);
+
+		using (var cmd = new MySqlCommand(@"select sum(b) from bulk_load_data_table;", connection))
+		{
+			using var reader = cmd.ExecuteReader();
+			Assert.True(reader.Read());
+			Assert.Equal(3.579m, reader.GetValue(0));
+			Assert.Equal("3.579", reader.GetMySqlDecimal(0).ToString().TrimEnd('0'));
+		}
+	}
+#endif
+
 	[Fact]
 	public void BulkCopyDataTableWithLongBlob()
 	{