lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-09-24 13:03:43 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Code collation

Browse Source
This commit is contained in:
sunkaixuan
2017-06-19 02:01:17 +08:00
parent 41d3af5277
commit d3516c872f
1 changed files with 32 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
SqlSugar/Abstract/SqlBuilderProvider/InsertBuilder.cs
View File

@@ -3,17 +3,21 @@ using System.Collections.Generic;
using System.Text; using System.Text;
using System.Linq; using System.Linq;
using System.Linq.Expressions; using System.Linq.Expressions;
namespace SqlSugar namespace SqlSugar
{ {
public class InsertBuilder : IDMLBuilder public class InsertBuilder : IDMLBuilder
{ {
#region Init
public InsertBuilder() public InsertBuilder()
{ {
this.sql = new StringBuilder(); this.sql = new StringBuilder();
this.Parameters = new List<SugarParameter>(); this.Parameters = new List<SugarParameter>();
this.DbColumnInfoList = new List<DbColumnInfo>(); this.DbColumnInfoList = new List<DbColumnInfo>();
} }
#endregion
#region Common Properties
public SqlSugarClient Context { get; set; } public SqlSugarClient Context { get; set; }
public ILambdaExpressions LambdaExpressions { get; set; } public ILambdaExpressions LambdaExpressions { get; set; }
public ISqlBuilder Builder { get; set; } public ISqlBuilder Builder { get; set; }
@@ -23,8 +27,10 @@ namespace SqlSugar
public List<DbColumnInfo> DbColumnInfoList { get; set; } public List<DbColumnInfo> DbColumnInfoList { get; set; }
public bool IsNoInsertNull { get; set; } public bool IsNoInsertNull { get; set; }
public bool IsReturnIdentity { get; set; } public bool IsReturnIdentity { get; set; }
public EntityInfo EntityInfo { get; set; } public EntityInfo EntityInfo { get; set; }
#endregion
#region SqlTemplate
public virtual string SqlTemplate public virtual string SqlTemplate
{ {
get get
@@ -46,19 +52,20 @@ namespace SqlSugar
} }
} }
} }
public virtual string SqlTemplateBatch
public virtual string SqlTemplateBatch { {
get { get
{
return "INSERT {0} ({1})"; return "INSERT {0} ({1})";
} }
} }
public virtual string SqlTemplateBatchSelect
public virtual string SqlTemplateBatchSelect { {
get { get
{
return "{0} AS {1}"; return "{0} AS {1}";
} }
} }
public virtual string SqlTemplateBatchUnion public virtual string SqlTemplateBatchUnion
{ {
get get
@@ -67,6 +74,9 @@ namespace SqlSugar
} }
} }
#endregion
#region Methods
public virtual void Clear() public virtual void Clear()
{ {
@@ -84,8 +94,6 @@ namespace SqlSugar
return result; return result;
} }
} }
public virtual ExpressionResult GetExpressionValue(Expression expression, ResolveExpressType resolveType) public virtual ExpressionResult GetExpressionValue(Expression expression, ResolveExpressType resolveType)
{ {
ILambdaExpressions resolveExpress = this.LambdaExpressions; ILambdaExpressions resolveExpress = this.LambdaExpressions;
@@ -112,16 +120,18 @@ namespace SqlSugar
string columnParametersString = string.Join(",", this.DbColumnInfoList.Select(it => Builder.SqlParameterKeyWord + it.DbColumnName)); string columnParametersString = string.Join(",", this.DbColumnInfoList.Select(it => Builder.SqlParameterKeyWord + it.DbColumnName));
return string.Format(SqlTemplate, GetTableNameString, columnsString, columnParametersString); return string.Format(SqlTemplate, GetTableNameString, columnsString, columnParametersString);
} }
else { else
{
StringBuilder batchInsetrSql = new StringBuilder(); StringBuilder batchInsetrSql = new StringBuilder();
int pageSize = 200; int pageSize = 200;
int pageIndex = 1; int pageIndex = 1;
int totalRecord = groupList.Count; int totalRecord = groupList.Count;
int pageCount = (totalRecord + pageSize - 1) / pageSize; int pageCount = (totalRecord + pageSize - 1) / pageSize;
while (pageCount >= pageIndex) { while (pageCount >= pageIndex)
{
batchInsetrSql.AppendFormat(SqlTemplateBatch, GetTableNameString, columnsString); batchInsetrSql.AppendFormat(SqlTemplateBatch, GetTableNameString, columnsString);
int i = 0; int i = 0;
foreach (var columns in groupList.Skip((pageIndex-1)*pageSize).Take(pageSize).ToList()) foreach (var columns in groupList.Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList())
{ {
var isFirst = i == 0; var isFirst = i == 0;
if (!isFirst) if (!isFirst)
@@ -137,27 +147,29 @@ namespace SqlSugar
return batchInsetrSql.ToString(); return batchInsetrSql.ToString();
} }
} }
public virtual object FormatValue(object value)
public object FormatValue(object value)
{ {
if (value == null) if (value == null)
{ {
return "NULL"; return "NULL";
} }
else { else
{
var type = value.GetType(); var type = value.GetType();
if (type == PubConst.DateType) if (type == PubConst.DateType)
{ {
return "'" + value.ObjToDate().ToString("yyyy-MM-dd hh:mm:ss.fff") + "'"; return "'" + value.ObjToDate().ToString("yyyy-MM-dd hh:mm:ss.fff") + "'";
} }
else if (type == PubConst.StringType|| type == PubConst.ObjType) else if (type == PubConst.StringType || type == PubConst.ObjType)
{ {
return "N'" + value.ToString().ToSqlFilter() + "'"; return "N'" + value.ToString().ToSqlFilter() + "'";
} }
else { else
{
return "N'" + value.ToString() + "'"; return "N'" + value.ToString() + "'";
} }
} }
} }
#endregion
} }
} }