1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192 |
- using Newtonsoft.Json.Linq;
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- namespace SqlSugar
- {
- public class JsonDeleteableProvider : IJsonDeleteableProvider<JsonDeleteResult>
- {
- private ISqlSugarClient context;
- private JObject jObject;
- private JsonCommonProvider jsonCommonProvider;
- private IDeleteable<object> sugarDeleteable=null;
- public JsonDeleteableProvider(ISqlSugarClient context, JObject jObject)
- {
- this.jObject = jObject;
- this.context = context;
- this.jsonCommonProvider = new JsonCommonProvider(context);
- }
- public SqlObjectResult ToSql()
- {
- return this.ToSqlList().First();
- }
- public List<SqlObjectResult> ToSqlList()
- {
- List<SqlObjectResult> result = new List<SqlObjectResult>();
- JsonQueryParameter jsonQueryParameter = new JsonQueryParameter();
- var appendTypeNames = this.jObject.AsJEnumerable().ToList();
- this.sugarDeleteable = this.context.Deleteable<object>();
- foreach (JToken item in appendTypeNames)
- {
- AppendAll(jsonQueryParameter, item);
- }
- result.Add(new SqlObjectResult(this.sugarDeleteable.ToSql(),JsonProviderType.Deleteable));
- return result;
- }
- private void AppendAll(JsonQueryParameter jsonQueryParameter, JToken item)
- {
- var name = item.Path.ToLower();
- if (IsWhere(name))
- {
- AppendWhere(item);
- }
- else if (IsTable(name))
- {
- AppendTable(item);
- }
- }
- private void AppendTable(JToken item)
- {
- var tableInfo = jsonCommonProvider.GetTableName(item);
- var tableName = tableInfo.TableName.ToCheckField();
- if (tableInfo.ShortName.HasValue())
- {
- tableName = tableInfo.ShortName + "." + tableInfo.TableName;
- }
- this.sugarDeleteable.AS(tableName);
- }
- private void AppendWhere(JToken item)
- {
- var sqlObj = jsonCommonProvider.GetWhere(item, sugarDeleteable.DeleteBuilder.Context);
- sugarDeleteable.Where(sqlObj.Key, sqlObj.Value);
- }
- private static bool IsTable(string name)
- {
- return name == JsonProviderConfig.KeyDeleteable.Get().ToLower();
- }
- private static bool IsWhere(string name)
- {
- return name == "Where".ToLower();
- }
- public string ToSqlString()
- {
- throw new NotImplementedException();
- }
- public JsonDeleteResult ToResult()
- {
- var result = new JsonDeleteResult();
- var sqlInfo = this.ToSqlList();
- var sqlInfoResult = sqlInfo.First();
- result.UpdateRows = this.context.Ado.ExecuteCommand(sqlInfoResult.Sql, sqlInfoResult.Parameters);
- return result;
- }
- List<string> IJsonProvider<JsonDeleteResult>.ToSqlString()
- {
- throw new NotImplementedException();
- }
- }
- }
|