lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-04-30 04:45:54 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update access core

Browse Source
This commit is contained in:
sunkaixuan 2022-08-30 21:39:58 +08:00
parent 5e2182c4e1
commit 1ebd23747a
3 changed files with 221 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
Src/Asp.NetCore2/SqlSugar.AccessCore/Access/AccessProvider.cs
View File

@ -8,6 +8,7 @@ using System.Data.OleDb;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
namespace SqlSugar.Access
{
@ -117,6 +118,56 @@ namespace SqlSugar.Access
}
return result;
}
public string SplitCommandTag = UtilConstants.ReplaceCommaKey;
public override int ExecuteCommand(string sql, SugarParameter[] parameters)
{
if (sql == null) throw new Exception("sql is null");
if (sql.IndexOf(this.SplitCommandTag) > 0)
{
var sqlParts = Regex.Split(sql, this.SplitCommandTag).Where(it => !string.IsNullOrEmpty(it)).ToList();
int result = 0;
foreach (var item in sqlParts)
{
if (item.TrimStart('\r').TrimStart('\n') != "")
{
result += base.ExecuteCommand(item, parameters);
}
}
return result;
}
else
{
if (sql.TrimStart('\r').TrimStart('\n') != "")
{
return base.ExecuteCommand(sql, parameters);
}
else
{
return 0;
}
}
}
public override async Task<int> ExecuteCommandAsync(string sql, SugarParameter[] parameters)
{
if (sql == null) throw new Exception("sql is null");
if (sql.IndexOf(this.SplitCommandTag) > 0)
{
var sqlParts = Regex.Split(sql, this.SplitCommandTag).Where(it => !string.IsNullOrEmpty(it)).ToList();
int result = 0;
foreach (var item in sqlParts)
{
if (item.TrimStart('\r').TrimStart('\n') != "")
{
result += await base.ExecuteCommandAsync(item, parameters);
}
}
return result;
}
else
{
return base.ExecuteCommand(sql, parameters);
}
}
/// <summary>
/// if mysql return MySqlParameter[] pars
/// if sqlerver return SqlParameter[] pars ...

105
Src/Asp.NetCore2/SqlSugar.AccessCore/Access/SqlBuilder/AccessInsertBuilder.cs
View File

@ -8,6 +8,13 @@ namespace SqlSugar.Access
{
public class AccessInsertBuilder : InsertBuilder
{
public override string SqlTemplateBatch
{
get
{
return "INSERT INTO {0} ({1})";
}
}
public override bool IsOleDb { get; set; } = true;
public override string SqlTemplate
{
@ -47,42 +54,98 @@ namespace SqlSugar.Access
else
{
StringBuilder batchInsetrSql = new StringBuilder();
int pageSize = 200;
if (this.EntityInfo.Columns.Count > 30)
{
pageSize = 50;
}
else if (this.EntityInfo.Columns.Count > 20)
{
pageSize = 100;
}
int pageSize = groupList.Count;
int pageIndex = 1;
int totalRecord = groupList.Count;
int pageCount = (totalRecord + pageSize - 1) / pageSize;
while (pageCount >= pageIndex)
{
batchInsetrSql.AppendFormat(SqlTemplateBatch, GetTableNameString, columnsString);
var temp=string.Format(SqlTemplateBatch, GetTableNameString, columnsString);
//batchInsetrSql.AppendFormat("\r\nSelect * FROM(");
int i = 0;
foreach (var columns in groupList.Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList())
{
var isFirst = i == 0;
if (!isFirst)
{
batchInsetrSql.Append(SqlTemplateBatchUnion);
}
batchInsetrSql.Append("\r\n SELECT " + string.Join(",", columns.Select(it => string.Format(SqlTemplateBatchSelect, FormatValue(it.Value), Builder.GetTranslationColumnName(it.DbColumnName)))));
//var isFirst = i == 0;
//if (!isFirst)
//{
// batchInsetrSql.Append("\t\r\nUNION ");
//}
//temp+" Values ( " + string.Join(",", columns.Select(it => FormatValue(it.Value) )+")"
batchInsetrSql.Append($"{temp} values ({string.Join(",", columns.Select(it => FormatValue(it.Value)))}) "+UtilConstants.ReplaceCommaKey);
++i;
}
pageIndex++;
batchInsetrSql.Append("\r\n;\r\n");
//batchInsetrSql.Append(") AS tblTemp\r\n");
}
var result = batchInsetrSql.ToString();
if (this.Context.CurrentConnectionConfig.DbType == DbType.SqlServer)
{
result += "select SCOPE_IDENTITY();";
}
return result;
}
}
public override object FormatValue(object value)
{
var n = "";
if (value == null)
{
return "NULL";
}
else
{
var type = UtilMethods.GetUnderType(value.GetType());
if (type == UtilConstants.DateType)
{
return GetDateTimeString(value);
}
else if (value is DateTimeOffset)
{
return GetDateTimeOffsetString(value);
}
else if (type == UtilConstants.ByteArrayType)
{
string bytesString = "0x" + BitConverter.ToString((byte[])value).Replace("-", "");
return bytesString;
}
else if (type.IsEnum())
{
if (this.Context.CurrentConnectionConfig.MoreSettings?.TableEnumIsString == true)
{
return value.ToSqlValue(); ;
}
else
{
return Convert.ToInt64(value);
}
}
else if (SqlSugar.UtilMethods.IsNumber(type.Name))
{
return value;
}
else if (type == UtilConstants.BoolType)
{
return value.ObjToBool() ? "1" : "0";
}
else
{
return n + "'" + value + "'";
}
}
}
private object GetDateTimeOffsetString(object value)
{
var date = UtilMethods.ConvertFromDateTimeOffset((DateTimeOffset)value);
if (date == DateTime.MinValue)
{
date = Convert.ToDateTime("1900-01-01");
}
return "'" + date.ToString("yyyy-MM-dd HH:mm") + "'";
}
private object GetDateTimeString(object value)
{
var date = value.ObjToDate();
if (date == DateTime.MinValue)
{
date = Convert.ToDateTime("1900-01-01");
}
return "'" + date.ToString("yyyy-MM-dd HH:mm") + "'";
}
}
}

95
Src/Asp.NetCore2/SqlSugar.AccessCore/Access/SqlBuilder/AccessUpdateBuilder.cs
View File

@ -10,19 +10,96 @@ namespace SqlSugar.Access
{
protected override string TomultipleSqlString(List<IGrouping<int, DbColumnInfo>> groupList)
{
if (groupList.Count == 0)
StringBuilder sb = new StringBuilder();
int i = 0;
sb.AppendLine(string.Join("", groupList.Select(t =>
{
return null;
var updateTable = string.Format("UPDATE {0} SET", base.GetTableNameStringNoWith);
var setValues = string.Join(",", t.Where(s => !s.IsPrimarykey).Select(m => GetOracleUpdateColums(i, m, false)).ToArray());
var pkList = t.Where(s => s.IsPrimarykey).ToList();
List<string> whereList = new List<string>();
foreach (var item in pkList)
{
var isFirst = pkList.First() == item;
var whereString = "";
whereString += GetOracleUpdateColums(i, item, true);
whereList.Add(whereString);
}
i++;
return string.Format("{0} {1} WHERE {2}", updateTable, setValues, string.Join(" AND", whereList)) + UtilConstants.ReplaceCommaKey;
}).ToArray()));
return sb.ToString();
}
private string GetOracleUpdateColums(int i, DbColumnInfo m, bool iswhere)
{
return string.Format("{0}={1}", m.DbColumnName , FormatValue(m.Value));
}
public override object FormatValue(object value)
{
var n = "";
if (value == null)
{
return "NULL";
}
else if (groupList.GroupBy(it => it.Key).Count() > 1)
else
{
throw new Exception("access no support batch update");
}
else
{
return ToSingleSqlString(groupList);
var type = UtilMethods.GetUnderType(value.GetType());
if (type == UtilConstants.DateType)
{
return GetDateTimeString(value);
}
else if (value is DateTimeOffset)
{
return GetDateTimeOffsetString(value);
}
else if (type == UtilConstants.ByteArrayType)
{
string bytesString = "0x" + BitConverter.ToString((byte[])value).Replace("-", "");
return bytesString;
}
else if (type.IsEnum())
{
if (this.Context.CurrentConnectionConfig.MoreSettings?.TableEnumIsString == true)
{
return value.ToSqlValue(); ;
}
else
{
return Convert.ToInt64(value);
}
}
else if (SqlSugar.UtilMethods.IsNumber(type.Name))
{
return value;
}
else if (type == UtilConstants.BoolType)
{
return value.ObjToBool() ? "1" : "0";
}
else
{
return n + "'" + value + "'";
}
}
}
private object GetDateTimeOffsetString(object value)
{
var date = UtilMethods.ConvertFromDateTimeOffset((DateTimeOffset)value);
if (date == DateTime.MinValue)
{
date = Convert.ToDateTime("1900-01-01");
}
return "'" + date.ToString("yyyy-MM-dd HH:mm") + "'";
}
private object GetDateTimeString(object value)
{
var date = value.ObjToDate();
if (date == DateTime.MinValue)
{
date = Convert.ToDateTime("1900-01-01");
}
return "'" + date.ToString("yyyy-MM-dd HH:mm") + "'";
}
}
}