JsonDeleteableProvider.cs 3.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. using Newtonsoft.Json.Linq;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Text;
  6. namespace SqlSugar
  7. {
  8. public class JsonDeleteableProvider : IJsonDeleteableProvider<JsonDeleteResult>
  9. {
  10. private ISqlSugarClient context;
  11. private JObject jObject;
  12. private JsonCommonProvider jsonCommonProvider;
  13. private IDeleteable<object> sugarDeleteable=null;
  14. public JsonDeleteableProvider(ISqlSugarClient context, JObject jObject)
  15. {
  16. this.jObject = jObject;
  17. this.context = context;
  18. this.jsonCommonProvider = new JsonCommonProvider(context);
  19. }
  20. public SqlObjectResult ToSql()
  21. {
  22. return this.ToSqlList().First();
  23. }
  24. public List<SqlObjectResult> ToSqlList()
  25. {
  26. List<SqlObjectResult> result = new List<SqlObjectResult>();
  27. JsonQueryParameter jsonQueryParameter = new JsonQueryParameter();
  28. var appendTypeNames = this.jObject.AsJEnumerable().ToList();
  29. this.sugarDeleteable = this.context.Deleteable<object>();
  30. foreach (JToken item in appendTypeNames)
  31. {
  32. AppendAll(jsonQueryParameter, item);
  33. }
  34. result.Add(new SqlObjectResult(this.sugarDeleteable.ToSql(),JsonProviderType.Deleteable));
  35. return result;
  36. }
  37. private void AppendAll(JsonQueryParameter jsonQueryParameter, JToken item)
  38. {
  39. var name = item.Path.ToLower();
  40. if (IsWhere(name))
  41. {
  42. AppendWhere(item);
  43. }
  44. else if (IsTable(name))
  45. {
  46. AppendTable(item);
  47. }
  48. }
  49. private void AppendTable(JToken item)
  50. {
  51. var tableInfo = jsonCommonProvider.GetTableName(item);
  52. var tableName = tableInfo.TableName.ToCheckField();
  53. if (tableInfo.ShortName.HasValue())
  54. {
  55. tableName = tableInfo.ShortName + "." + tableInfo.TableName;
  56. }
  57. this.sugarDeleteable.AS(tableName);
  58. }
  59. private void AppendWhere(JToken item)
  60. {
  61. var sqlObj = jsonCommonProvider.GetWhere(item, sugarDeleteable.DeleteBuilder.Context);
  62. sugarDeleteable.Where(sqlObj.Key, sqlObj.Value);
  63. }
  64. private static bool IsTable(string name)
  65. {
  66. return name == JsonProviderConfig.KeyDeleteable.Get().ToLower();
  67. }
  68. private static bool IsWhere(string name)
  69. {
  70. return name == "Where".ToLower();
  71. }
  72. public string ToSqlString()
  73. {
  74. throw new NotImplementedException();
  75. }
  76. public JsonDeleteResult ToResult()
  77. {
  78. var result = new JsonDeleteResult();
  79. var sqlInfo = this.ToSqlList();
  80. var sqlInfoResult = sqlInfo.First();
  81. result.UpdateRows = this.context.Ado.ExecuteCommand(sqlInfoResult.Sql, sqlInfoResult.Parameters);
  82. return result;
  83. }
  84. List<string> IJsonProvider<JsonDeleteResult>.ToSqlString()
  85. {
  86. throw new NotImplementedException();
  87. }
  88. }
  89. }