lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-09-18 17:48:11 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update MySql

Browse Source
This commit is contained in:
sunkaixuan
2017-06-23 16:46:59 +08:00
parent b9c2271007
commit 643061af07
2 changed files with 37 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
Src/Asp.Net/SqlSugar/Realization/MySql/DbBind/MySqlDbBind.cs
View File

@@ -9,7 +9,14 @@ namespace SqlSugar
{
get
{
throw new NotImplementedException();
return new List<KeyValuePair<string, CSharpDataType>>()
{
new KeyValuePair<string, CSharpDataType>("tinyint",CSharpDataType.@byte),
new KeyValuePair<string, CSharpDataType>("smallint",CSharpDataType.@short),
new KeyValuePair<string, CSharpDataType>("mediumint",CSharpDataType.@int),
new KeyValuePair<string, CSharpDataType>("int",CSharpDataType.@int),
new KeyValuePair<string, CSharpDataType>("integer",CSharpDataType.@int),
};
}
}
}

54
Src/Asp.Net/SqlSugar/Realization/MySql/MySqlProvider.cs
View File

@@ -1,13 +1,16 @@
using System;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using MySql.Data.MySqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace SqlSugar
{
public class MySqlProvider : AdoProvider
{
public MySqlProvider() {}
public MySqlProvider() { }
public override IDbConnection Connection
{
get
@@ -23,13 +26,10 @@ namespace SqlSugar
base._DbConnection = value;
}
}
/// <summary>
/// Only SqlServer
/// </summary>
/// <param name="transactionName"></param>
public override void BeginTran(string transactionName)
{
throw new NotImplementedException();
((MySqlConnection)this.Connection).BeginTransaction();
}
/// <summary>
/// Only SqlServer
@@ -38,7 +38,7 @@ namespace SqlSugar
/// <param name="transactionName"></param>
public override void BeginTran(IsolationLevel iso, string transactionName)
{
throw new NotImplementedException();
((MySqlConnection)this.Connection).BeginTransaction(iso);
}
public override IDataAdapter GetAdapter()
{
@@ -55,8 +55,8 @@ namespace SqlSugar
}
if (parameters.IsValuable())
{
IDataParameter[] ipars= ToIDbDataParameter(parameters);
sqlCommand.Parameters.AddRange((SqlParameter[])ipars);
IDataParameter[] ipars = ToIDbDataParameter(parameters);
sqlCommand.Parameters.AddRange((MySqlParameter[])ipars);
}
CheckConnection();
return sqlCommand;
@@ -74,20 +74,24 @@ namespace SqlSugar
public override IDataParameter[] ToIDbDataParameter(params SugarParameter[] parameters)
{
if (parameters == null || parameters.Length == 0) return null;
SqlParameter[] result = new SqlParameter[parameters.Length];
int i = 0;
foreach (var paramter in parameters)
MySqlParameter[] result = new MySqlParameter[parameters.Length];
int index = 0;
foreach (var parameter in parameters)
{
if (paramter.Value == null) paramter.Value = DBNull.Value;
var p = new SqlParameter();
p.ParameterName = paramter.ParameterName;
p.UdtTypeName = paramter.UdtTypeName;
p.Size = paramter.Size;
p.Value = paramter.Value;
p.DbType = paramter.DbType;
p.Direction = paramter.Direction;
result[i] =p;
++i;
if (parameter.Value == null) parameter.Value = DBNull.Value;
var sqlParameter = new MySqlParameter();
sqlParameter.ParameterName = parameter.ParameterName;
sqlParameter.Size = parameter.Size;
sqlParameter.Value = parameter.Value;
sqlParameter.DbType = parameter.DbType;
sqlParameter.Direction = parameter.Direction;
result[index] = sqlParameter;
if (sqlParameter.Direction == ParameterDirection.Output) {
if (this.OutputParameters == null) this.OutputParameters = new List<IDataParameter>();
this.OutputParameters.RemoveAll(it => it.ParameterName == sqlParameter.ParameterName);
this.OutputParameters.Add(sqlParameter);
}
++index;
}
return result;
}