Add support for DataSourceInformation Schema (#795)

Some progress on the #375 issue.

Author: vdaron

src/MySqlConnector/Core/SchemaProvider.cs

@@ -2,6 +2,7 @@
 using System;
 using System.Collections.Generic;
 using System.Data;
+using System.Data.Common;
 using System.Linq;
 using MySql.Data.MySqlClient;
 
@@ -14,6 +15,7 @@ public SchemaProvider(MySqlConnection connection)
 			m_connection = connection;
 			m_schemaCollections = new Dictionary<string, Action<DataTable>>
 			{
+				{ "DataSourceInformation", FillDataSourceInformation},
 				{ "MetaDataCollections", FillMetadataCollections },
 				{ "CharacterSets", FillCharacterSets },
 				{ "Collations", FillCollations },
@@ -58,6 +60,55 @@ public DataTable GetSchema(string collectionName)
 			return dataTable;
 		}
 
+		private void FillDataSourceInformation(DataTable dataTable)
+		{
+			dataTable.Columns.AddRange(new [] {
+				new DataColumn("CompositeIdentifierSeparatorPattern", typeof(string)),
+				new DataColumn("DataSourceProductName", typeof(string)),
+				new DataColumn("DataSourceProductVersion", typeof(string)),
+				new DataColumn("DataSourceProductVersionNormalized", typeof(string)),
+				new DataColumn("GroupByBehavior", typeof(GroupByBehavior)),
+				new DataColumn("IdentifierPattern", typeof(string)),
+				new DataColumn("IdentifierCase", typeof(IdentifierCase)),
+				new DataColumn("OrderByColumnsInSelect", typeof(bool)),
+				new DataColumn("ParameterMarkerFormat", typeof(string)),
+				new DataColumn("ParameterMarkerPattern", typeof(string)),
+				new DataColumn("ParameterNameMaxLength", typeof(int)),
+				new DataColumn("QuotedIdentifierPattern", typeof(string)),
+				new DataColumn("QuotedIdentifierCase", typeof(IdentifierCase)),
+				new DataColumn("ParameterNamePattern", typeof(string)),
+				new DataColumn("StatementSeparatorPattern", typeof(string)),
+				new DataColumn("StringLiteralPattern", typeof(string)),
+				new DataColumn("SupportedJoinOperators", typeof(SupportedJoinOperators))
+			});
+
+			var row = dataTable.NewRow();
+			row["CompositeIdentifierSeparatorPattern"] = @"\.";
+			row["DataSourceProductName"] = "MySQL";
+			row["DataSourceProductVersion"] = m_connection.ServerVersion;
+			row["DataSourceProductVersionNormalized"] = GetVersion(m_connection.Session.ServerVersion.Version);
+			row["GroupByBehavior"] = GroupByBehavior.Unrelated;
+			row["IdentifierPattern"] = @"(^\[\p{Lo}\p{Lu}\p{Ll}_@#][\p{Lo}\p{Lu}\p{Ll}\p{Nd}@$#_]*$)|(^\[[^\]\0]|\]\]+\]$)|(^\""[^\""\0]|\""\""+\""$)";
+			row["IdentifierCase"] = IdentifierCase.Insensitive;
+			row["OrderByColumnsInSelect"] = false;
+			row["ParameterMarkerFormat"] = @"{0}";
+			row["ParameterMarkerPattern"] = @"(@[A-Za-z0-9_$#]*)";
+			row["ParameterNameMaxLength"] = 128; // For function out parameters
+			row["QuotedIdentifierPattern"] = @"(([^\`]|\`\`)*)";
+			row["QuotedIdentifierCase"] = IdentifierCase.Sensitive;
+			row["ParameterNamePattern"] = @"^[\p{Lo}\p{Lu}\p{Ll}\p{Lm}_@#][\p{Lo}\p{Lu}\p{Ll}\p{Lm}\p{Nd}\uff3f_@#\$]*(?=\s+|$)";
+			row["StatementSeparatorPattern"] = ";";
+			row["StringLiteralPattern"] = @"'(([^']|'')*)'";
+			row["SupportedJoinOperators"] =
+				SupportedJoinOperators.FullOuter |
+				SupportedJoinOperators.Inner |
+				SupportedJoinOperators.LeftOuter |
+				SupportedJoinOperators.RightOuter;
+			dataTable.Rows.Add(row);
+		}
+
+		private string GetVersion(Version v) => $"{v.Major:00}.{v.Minor:00}.{v.Build:0000}";
+
 		private void FillMetadataCollections(DataTable dataTable)
 		{
 			dataTable.Columns.AddRange(new[] {

tests/SideBySide/ConnectionTests.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Data;
+using System.Data.Common;
 using Dapper;
 using MySql.Data.MySqlClient;
 using Xunit;
@@ -241,6 +242,17 @@ public void CloneWithCopiesExistingPassword()
 			connection2.Open();
 			Assert.Equal(ConnectionState.Open, connection2.State);
 		}
+#endif
+#if !NETCOREAPP1_1_2
+		[Fact]
+		public void GetDataSourceInformationSchemaCollection()
+		{
+			using var connection = new MySqlConnection(AppConfig.ConnectionString);
+			connection.Open();
+
+			var dataTable = connection.GetSchema(DbMetaDataCollectionNames.DataSourceInformation);
+			Assert.Equal(connection.ServerVersion, dataTable.Rows[0]["DataSourceProductVersion"]);
+		}
 #endif
 	}
 }