Added support for Json type. (WL # 8132).

Author: Gabriela Martinez

CHANGES

@@ -1,6 +1,7 @@
 6.7.9
 - Changed handshake process to use bytes instead of encoded strings.
 - Added support for Chinese character set gb18030. (Oracle bug # 21098546).
+- Added support for Json type. (WL # 8132).
 
 
 6.7.8

Source/MySql.Data.Entity/MySql.Data.Entity.csproj

@@ -178,7 +178,7 @@
     <Compile Include="Generators\Scope.cs" />
     <Compile Include="Generators\SelectGenerator.cs" />
     <Compile Include="Generators\SqlGenerator.cs" />
-    <Compile Include="Generators\UpdateGenerator.cs" />    
+    <Compile Include="Generators\UpdateGenerator.cs" />
     <Compile Include="MySqlConnectionFactory.cs" Condition="$(Framework) == '4.0' or $(Framework) == '4.5'" />
     <Compile Include="MySqlMigrationSqlGenerator.cs" Condition="$(Framework) == '4.0' or $(Framework) == '4.5'" />
     <Compile Include="MySqlSpatialServices.cs" Condition="$(Framework) == '4.5'" />
@@ -195,7 +195,7 @@
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="ProviderServices.cs" />
     <Compile Include="Statements\SelectStatement.cs" />
-    <Compile Include="Statements\UpdateStatement.cs" />	
+    <Compile Include="Statements\UpdateStatement.cs" />
     <EmbeddedResource Include="Properties\SchemaDefinition-5.0.ssdl" />
     <EmbeddedResource Include="Properties\SchemaDefinition-5.5.ssdl" />
     <EmbeddedResource Include="Properties\SchemaDefinition-5.1.ssdl" />
@@ -211,28 +211,29 @@
       <Project>{E9DF5ED1-4CBD-4226-B931-9A51610AC14D}</Project>
       <Name>MySql.Data</Name>
     </ProjectReference>
-  </ItemGroup>  
+  </ItemGroup>
   <ItemGroup>
     <EmbeddedResource Include="Properties\SchemaDefinition-5.6.ssdl">
       <SubType>Designer</SubType>
     </EmbeddedResource>
   </ItemGroup>
   <Choose>
-	<When Condition="'$(Framework)' == '4.5'">
-		<ItemGroup>  		
-			<EmbeddedResource Include="Properties\4.5\ProviderManifest.xml">					
-				<LogicalName>MySql.Data.Entity.Properties.ProviderManifest.xml</LogicalName>
-			</EmbeddedResource>
-		</ItemGroup>  
-	</When>
-	<Otherwise>
-		<ItemGroup>  	
-			<EmbeddedResource Include="Properties\ProviderManifest.xml" >					
-				<LogicalName>MySql.Data.Entity.Properties.ProviderManifest.xml</LogicalName>
-			</EmbeddedResource>
-		</ItemGroup>
-	</Otherwise>  	
-  </Choose>  
+    <When Condition="'$(Framework)' == '4.5'">
+      <ItemGroup>
+        <EmbeddedResource Include="Properties\4.5\ProviderManifest.xml">
+          <LogicalName>MySql.Data.Entity.Properties.ProviderManifest.xml</LogicalName>
+          <SubType>Designer</SubType>
+        </EmbeddedResource>
+      </ItemGroup>
+    </When>
+    <Otherwise>
+      <ItemGroup>
+        <EmbeddedResource Include="Properties\ProviderManifest.xml">
+          <LogicalName>MySql.Data.Entity.Properties.ProviderManifest.xml</LogicalName>
+        </EmbeddedResource>
+      </ItemGroup>
+    </Otherwise>
+  </Choose>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.

Source/MySql.Data/Field.cs

@@ -1,4 +1,4 @@
-// Copyright © 2004, 2013, Oracle and/or its affiliates. All rights reserved.
+// Copyright © 2004, 2015, Oracle and/or its affiliates. All rights reserved.
 //
 // MySQL Connector/NET is licensed under the terms of the GPLv2
 // <http://www.gnu.org/licenses/old-licenses/gpl-2.0.html>, like most 
@@ -374,6 +374,7 @@ public static IMySqlValue GetIMySqlValue(MySqlDbType type)
         case MySqlDbType.TinyText:
         case MySqlDbType.MediumText:
         case MySqlDbType.LongText:
+        case MySqlDbType.JSON:
         case (MySqlDbType)Field_Type.NULL:
           return new MySqlString(type, true);
 #if !CF

Source/MySql.Data/MysqlDefs.cs

@@ -1,4 +1,4 @@
-// Copyright © 2004, 2011, 2013, Oracle and/or its affiliates. All rights reserved.
+// Copyright © 2004, 2015 Oracle and/or its affiliates. All rights reserved.
 //
 // MySQL Connector/NET is licensed under the terms of the GPLv2
 // <http://www.gnu.org/licenses/old-licenses/gpl-2.0.html>, like most 
@@ -201,6 +201,10 @@ public enum MySqlDbType
     /// </summary>
     Bit = 16,
     /// <summary>
+    /// JSON
+    /// </summary>
+    JSON = 245,
+    /// <summary>
     /// New Decimal
     /// </summary>
     NewDecimal = 246,

Tests/MySql.Data.Tests/DataTypeTests.cs

@@ -1,4 +1,4 @@
-// Copyright © 2013, 2014 Oracle and/or its affiliates. All rights reserved.
+// Copyright © 2013, 2015 Oracle and/or its affiliates. All rights reserved.
 //
 // MySQL Connector/NET is licensed under the terms of the GPLv2
 // <http://www.gnu.org/licenses/old-licenses/gpl-2.0.html>, like most 
@@ -1277,5 +1277,52 @@ public void Timediff()
       var result = cmd.ExecuteScalar();
       Assert.Equal(new TimeSpan(new TimeSpan(-2, -1, -1, -2).Ticks - 1234560), result);
     }
+
+    [Fact]
+    public void CanReadJsonValue()
+    {
+      st.execSQL("DROP TABLE IF EXISTS test");
+      st.execSQL("CREATE TABLE test(Id int NOT NULL PRIMARY KEY, jsoncolumn JSON)");
+    
+      MySqlCommand cmd = new MySqlCommand("INSERT INTO test VALUES (@id, '[1]')", st.conn);
+      cmd.Parameters.AddWithValue("@id", 1);
+      cmd.ExecuteNonQuery();
+
+      string command = @"INSERT INTO test VALUES (@id, '[""a"", {""b"": [true, false]}, [10, 20]]')";
+      cmd = new MySqlCommand(command, st.conn);
+      cmd.Parameters.AddWithValue("@id", 2);
+      cmd.ExecuteNonQuery();
+
+      cmd = new MySqlCommand("SELECT jsoncolumn from test where id = 2 ", st.conn);
+
+      using (MySqlDataReader reader = cmd.ExecuteReader())
+      {
+        Assert.True(reader.Read());
+        Assert.Equal("[\"a\", {\"b\": [true, false]}, [10, 20]]", reader.GetString(0));
+      }    
+    }
+
+    [Fact]
+    public void CanUpdateJsonValue()
+    {
+      st.execSQL("DROP TABLE IF EXISTS test");
+      st.execSQL("CREATE TABLE test(Id int NOT NULL PRIMARY KEY, jsoncolumn JSON)");
+
+      MySqlCommand cmd = new MySqlCommand("INSERT INTO test VALUES (@id, '[1]')", st.conn);
+      cmd.Parameters.AddWithValue("@id", 1);
+      cmd.ExecuteNonQuery();
+
+      string command = @"UPDATE test set jsoncolumn = '[""a"", {""b"": [true, false]}, [10, 20]]' where id = 1";
+      cmd = new MySqlCommand(command, st.conn);      
+      cmd.ExecuteNonQuery();
+
+      cmd = new MySqlCommand("SELECT jsoncolumn from test where id = 1 ", st.conn);
+
+      using (MySqlDataReader reader = cmd.ExecuteReader())
+      {
+        Assert.True(reader.Read());
+        Assert.Equal("[\"a\", {\"b\": [true, false]}, [10, 20]]", reader.GetString(0));
+      }
+    }
   }
 }