Support BigInteger as parameter. Fixes #1069

Author: bgrainger

src/MySqlConnector/MySqlParameter.cs

@@ -1,6 +1,8 @@
 using System.Buffers.Text;
 using System.Diagnostics;
 using System.Diagnostics.CodeAnalysis;
+using System.Globalization;
+using System.Numerics;
 using System.Text;
 using MySqlConnector.Core;
 using MySqlConnector.Protocol.Serialization;
@@ -314,6 +316,10 @@ internal void AppendSqlString(ByteBufferWriter writer, StatementPreparerOptions
 			// NOTE: Utf8Formatter doesn't support "R"
 			writer.Write("{0:R}".FormatInvariant(Value));
 		}
+		else if (Value is BigInteger bigInteger)
+		{
+			writer.Write(bigInteger.ToString(CultureInfo.InvariantCulture));
+		}
 		else if (Value is MySqlDateTime mySqlDateTimeValue)
 		{
 			if (mySqlDateTimeValue.IsValidDateTime)
@@ -594,6 +600,10 @@ internal void AppendBinary(ByteBufferWriter writer, StatementPreparerOptions opt
 		{
 			writer.WriteLengthEncodedString("{0}".FormatInvariant(Value));
 		}
+		else if (Value is BigInteger bigInteger)
+		{
+			writer.WriteLengthEncodedString(bigInteger.ToString(CultureInfo.InvariantCulture));
+		}
 		else if (Value is MySqlDateTime mySqlDateTimeValue)
 		{
 			if (mySqlDateTimeValue.IsValidDateTime)

tests/SideBySide/InsertTests.cs

@@ -1,3 +1,4 @@
+using System.Numerics;
 #if BASELINE
 using MySql.Data.Types;
 #endif
@@ -387,6 +388,52 @@ public void InsertStringBuilder(bool prepare)
 		Assert.Equal(expected, reader.GetValue(0));
 	}
 
+	[Theory]
+	[InlineData(false)]
+	[InlineData(true)]
+	public void InsertBigInteger(bool prepare)
+	{
+		using var connection = new MySqlConnection(AppConfig.ConnectionString);
+		connection.Open();
+		connection.Execute(@"drop table if exists insert_big_integer;
+create table insert_big_integer(rowid integer not null primary key auto_increment, value bigint);");
+
+		var value = 1_000_000_000_000_000L;
+		using var cmd = connection.CreateCommand();
+		cmd.CommandText = @"insert into insert_big_integer(value) values(@value);";
+		cmd.Parameters.AddWithValue("@value", new BigInteger(value));
+		if (prepare)
+			cmd.Prepare();
+		cmd.ExecuteNonQuery();
+
+		using var reader = connection.ExecuteReader(@"select value from insert_big_integer order by rowid;");
+		Assert.True(reader.Read());
+		Assert.Equal(value, reader.GetValue(0));
+	}
+
+	[Theory]
+	[InlineData(false)]
+	[InlineData(true)]
+	public void InsertBigIntegerAsDecimal(bool prepare)
+	{
+		using var connection = new MySqlConnection(AppConfig.ConnectionString);
+		connection.Open();
+		connection.Execute(@"drop table if exists insert_big_integer;
+create table insert_big_integer(rowid integer not null primary key auto_increment, value decimal(40, 2));");
+
+		var value = long.MaxValue * 1000m;
+		using var cmd = connection.CreateCommand();
+		cmd.CommandText = @"insert into insert_big_integer(value) values(@value);";
+		cmd.Parameters.AddWithValue("@value", new BigInteger(value));
+		if (prepare)
+			cmd.Prepare();
+		cmd.ExecuteNonQuery();
+
+		using var reader = connection.ExecuteReader(@"select value from insert_big_integer order by rowid;");
+		Assert.True(reader.Read());
+		Assert.Equal(value, reader.GetValue(0));
+	}
+
 	[Fact]
 	public void InsertOldGuid()
 	{