QuestDBExpressionContext.cs 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381
  1. using System;
  2. using System.Linq;
  3. namespace SqlSugar
  4. {
  5. public class QuestDBExpressionContext : ExpressionContext, ILambdaExpressions
  6. {
  7. public SqlSugarProvider Context { get; set; }
  8. public QuestDBExpressionContext()
  9. {
  10. base.DbMehtods = new QuestDBMethod();
  11. }
  12. public override string SqlTranslationLeft
  13. {
  14. get
  15. {
  16. return "\"";
  17. }
  18. }
  19. public override string SqlTranslationRight
  20. {
  21. get
  22. {
  23. return "\"";
  24. }
  25. }
  26. public override string GetTranslationText(string name)
  27. {
  28. return SqlTranslationLeft + name.ToLower(isAutoToLower) + SqlTranslationRight;
  29. }
  30. public bool isAutoToLower
  31. {
  32. get
  33. {
  34. return false;
  35. }
  36. }
  37. public override string GetTranslationTableName(string entityName, bool isMapping = true)
  38. {
  39. Check.ArgumentNullException(entityName, string.Format(ErrorMessage.ObjNotExist, "Table Name"));
  40. if (IsTranslationText(entityName)) return entityName;
  41. isMapping = isMapping && this.MappingTables.HasValue();
  42. var isComplex = entityName.Contains(UtilConstants.Dot);
  43. if (isMapping && isComplex)
  44. {
  45. var columnInfo = entityName.Split(UtilConstants.DotChar);
  46. var mappingInfo = this.MappingTables.FirstOrDefault(it => it.EntityName.Equals(columnInfo.Last(), StringComparison.CurrentCultureIgnoreCase));
  47. if (mappingInfo != null)
  48. {
  49. columnInfo[columnInfo.Length - 1] = mappingInfo.EntityName;
  50. }
  51. return string.Join(UtilConstants.Dot, columnInfo.Select(it => GetTranslationText(it)));
  52. }
  53. else if (isMapping)
  54. {
  55. var mappingInfo = this.MappingTables.FirstOrDefault(it => it.EntityName.Equals(entityName, StringComparison.CurrentCultureIgnoreCase));
  56. var tableName = mappingInfo?.DbTableName+"";
  57. if (tableName.Contains("."))
  58. {
  59. tableName = string.Join(UtilConstants.Dot, tableName.Split(UtilConstants.DotChar).Select(it => GetTranslationText(it)));
  60. return tableName;
  61. }
  62. return SqlTranslationLeft + (mappingInfo == null ? entityName : mappingInfo.DbTableName).ToLower(isAutoToLower) + SqlTranslationRight;
  63. }
  64. else if (isComplex)
  65. {
  66. return string.Join(UtilConstants.Dot, entityName.Split(UtilConstants.DotChar).Select(it => GetTranslationText(it)));
  67. }
  68. else
  69. {
  70. return GetTranslationText(entityName);
  71. }
  72. }
  73. public override string GetTranslationColumnName(string columnName)
  74. {
  75. Check.ArgumentNullException(columnName, string.Format(ErrorMessage.ObjNotExist, "Column Name"));
  76. if (columnName.Substring(0, 1) == this.SqlParameterKeyWord)
  77. {
  78. return columnName;
  79. }
  80. if (IsTranslationText(columnName)) return columnName;
  81. if (columnName.Contains(UtilConstants.Dot))
  82. {
  83. return string.Join(UtilConstants.Dot, columnName.Split(UtilConstants.DotChar).Select(it => GetTranslationText(it)));
  84. }
  85. else
  86. {
  87. return GetTranslationText(columnName);
  88. }
  89. }
  90. public override string GetDbColumnName(string entityName, string propertyName)
  91. {
  92. if (this.MappingColumns.HasValue())
  93. {
  94. var mappingInfo = this.MappingColumns.SingleOrDefault(it => it.EntityName == entityName && it.PropertyName == propertyName);
  95. return (mappingInfo == null ? propertyName : mappingInfo.DbColumnName).ToLower(isAutoToLower);
  96. }
  97. else
  98. {
  99. return propertyName.ToLower(isAutoToLower);
  100. }
  101. }
  102. public string GetValue(object entityValue)
  103. {
  104. if (entityValue == null)
  105. return null;
  106. var type = UtilMethods.GetUnderType(entityValue.GetType());
  107. if (UtilConstants.NumericalTypes.Contains(type))
  108. {
  109. return entityValue.ToString();
  110. }
  111. else if (type == UtilConstants.DateType)
  112. {
  113. return this.DbMehtods.ToDate(new MethodCallExpressionModel()
  114. {
  115. Args = new System.Collections.Generic.List<MethodCallExpressionArgs>() {
  116. new MethodCallExpressionArgs(){ MemberName=$"'{entityValue}'" }
  117. }
  118. });
  119. }
  120. else
  121. {
  122. return this.DbMehtods.ToString(new MethodCallExpressionModel()
  123. {
  124. Args = new System.Collections.Generic.List<MethodCallExpressionArgs>() {
  125. new MethodCallExpressionArgs(){ MemberName=$"'{entityValue}'" }
  126. }
  127. });
  128. }
  129. }
  130. }
  131. public class QuestDBMethod : DefaultDbMethod, IDbMethods
  132. {
  133. //public override string DateIsSameByType(MethodCallExpressionModel model)
  134. //{
  135. // var parameter = model.Args[0];
  136. // var parameter2 = model.Args[1];
  137. // var parameter3 = model.Args[2];
  138. // return string.Format(" (DATEDIFF('{2}',{0},{1})=0) ", parameter.MemberName, parameter2.MemberName, parameter3.MemberValue);
  139. //}
  140. public override string AggregateCount(MethodCallExpressionModel model)
  141. {
  142. return " COUNT(*) ";
  143. }
  144. public override string Contains(MethodCallExpressionModel model)
  145. {
  146. var parameter = model.Args[0];
  147. var parameter2 = model.Args[1];
  148. return string.Format(" ({0}~{1} ) ", parameter.MemberName, parameter2.MemberName);
  149. }
  150. public override string DateDiff(MethodCallExpressionModel model)
  151. {
  152. var parameter = model.Args[0];
  153. var parameter2 = model.Args[1];
  154. var parameter3 = model.Args[2];
  155. return string.Format(" DATEDIFF('{0}',{1},{2}) ", parameter.MemberValue.ObjToString().ToLower().First(), parameter2.MemberName, parameter3.MemberName);
  156. }
  157. public override string TrueValue()
  158. {
  159. return "1";
  160. }
  161. public override string FalseValue()
  162. {
  163. return "0";
  164. }
  165. //public override string DateDiff(MethodCallExpressionModel model)
  166. //{
  167. // var parameter = (DateType)(Enum.Parse(typeof(DateType), model.Args[0].MemberValue.ObjToString()));
  168. // var begin = model.Args[1].MemberName;
  169. // var end = model.Args[2].MemberName;
  170. // switch (parameter)
  171. // {
  172. // case DateType.Year:
  173. // return $" ( DATE_PART('Year', {end} ) - DATE_PART('Year', {begin}) )";
  174. // case DateType.Month:
  175. // return $" ( ( DATE_PART('Year', {end} ) - DATE_PART('Year', {begin}) ) * 12 + (DATE_PART('month', {end}) - DATE_PART('month', {begin})) )";
  176. // case DateType.Day:
  177. // return $" ( DATE_PART('day', {end} - {begin}) )";
  178. // case DateType.Hour:
  179. // return $" ( ( DATE_PART('day', {end} - {begin}) ) * 24 + DATE_PART('hour', {end} - {begin} ) )";
  180. // case DateType.Minute:
  181. // return $" ( ( ( DATE_PART('day', {end} - {begin}) ) * 24 + DATE_PART('hour', {end} - {begin} ) ) * 60 + DATE_PART('minute', {end} - {begin} ) )";
  182. // case DateType.Second:
  183. // return $" ( ( ( DATE_PART('day', {end} - {begin}) ) * 24 + DATE_PART('hour', {end} - {begin} ) ) * 60 + DATE_PART('minute', {end} - {begin} ) ) * 60 + DATE_PART('minute', {end} - {begin} )";
  184. // case DateType.Millisecond:
  185. // break;
  186. // default:
  187. // break;
  188. // }
  189. // throw new Exception(parameter + " datediff no support");
  190. //}
  191. public override string IIF(MethodCallExpressionModel model)
  192. {
  193. var parameter = model.Args[0];
  194. var parameter2 = model.Args[1];
  195. var parameter3 = model.Args[2];
  196. if (parameter.Type == UtilConstants.BoolType)
  197. {
  198. parameter.MemberName = parameter.MemberName.ToString().Replace("=1", "=true");
  199. parameter2.MemberName = false;
  200. parameter3.MemberName = true;
  201. }
  202. return string.Format("( CASE WHEN {0} THEN {1} ELSE {2} END )", parameter.MemberName, parameter2.MemberName, parameter3.MemberName);
  203. }
  204. public override string DateValue(MethodCallExpressionModel model)
  205. {
  206. var parameter = model.Args[0];
  207. var parameter2 = model.Args[1];
  208. var format = parameter2.MemberValue.ObjToString();
  209. return string.Format(" {0}({1}) ", format, parameter.MemberName);
  210. }
  211. public override string StartsWith(MethodCallExpressionModel model)
  212. {
  213. var parameter = model.Args[0];
  214. var parameter2 = model.Args[1];
  215. return string.Format(" ({0} like concat({1},'%')) ", parameter.MemberName, parameter2.MemberName);
  216. }
  217. public override string EndsWith(MethodCallExpressionModel model)
  218. {
  219. var parameter = model.Args[0];
  220. var parameter2 = model.Args[1];
  221. return string.Format(" ({0} like concat('%',{1}))", parameter.MemberName,parameter2.MemberName);
  222. }
  223. public override string DateIsSameDay(MethodCallExpressionModel model)
  224. {
  225. var parameter = model.Args[0];
  226. var parameter2 = model.Args[1];
  227. return string.Format(" ( to_char({0},'yyyy-MM-dd')=to_char({1},'yyyy-MM-dd') ) ", parameter.MemberName, parameter2.MemberName); ;
  228. }
  229. public override string HasValue(MethodCallExpressionModel model)
  230. {
  231. var parameter = model.Args[0];
  232. return string.Format("( {0} IS NOT NULL )", parameter.MemberName);
  233. }
  234. public override string DateIsSameByType(MethodCallExpressionModel model)
  235. {
  236. var parameter = model.Args[0];
  237. var parameter2 = model.Args[1];
  238. var parameter3 = model.Args[2];
  239. DateType dateType =(DateType)parameter3.MemberValue;
  240. var format = "yyyy-MM-dd";
  241. switch (dateType)
  242. {
  243. case DateType.Year:
  244. format = "yyyy";
  245. break;
  246. case DateType.Month:
  247. format = "yyyy-MM";
  248. break;
  249. case DateType.Day:
  250. break;
  251. case DateType.Hour:
  252. format = "yyyy-MM-dd HH";
  253. break;
  254. case DateType.Second:
  255. format = "yyyy-MM-dd HH:mm:ss";
  256. break;
  257. case DateType.Minute:
  258. format = "yyyy-MM-dd HH:mm";
  259. break;
  260. case DateType.Millisecond:
  261. format = "yyyy-MM-dd HH:mm.ms";
  262. break;
  263. default:
  264. break;
  265. }
  266. return string.Format(" ( to_char({0},'{2}')=to_char({1},'{2}') ) ", parameter.MemberName, parameter2.MemberName, format);
  267. }
  268. public override string ToDateShort(MethodCallExpressionModel model)
  269. {
  270. var parameter = model.Args[0];
  271. return string.Format("to_date (to_str({0}, 'yyyy-MM-dd'),'yyyy-MM-dd')", parameter.MemberName);
  272. }
  273. public override string ToDate(MethodCallExpressionModel model)
  274. {
  275. var parameter = model.Args[0];
  276. return string.Format("CAST({0} AS timestamp)", parameter.MemberName);
  277. }
  278. public override string DateAddByType(MethodCallExpressionModel model)
  279. {
  280. var parameter = model.Args[0];
  281. var parameter2 = model.Args[1];
  282. var parameter3 = model.Args[2];
  283. return string.Format(" (DATEADD('{0}',{2}, {1})) ", parameter3.MemberValue.ObjToString().ToLower().First(), parameter.MemberName, parameter2.MemberValue);
  284. }
  285. public override string DateAddDay(MethodCallExpressionModel model)
  286. {
  287. var parameter = model.Args[0];
  288. var parameter2 = model.Args[1];
  289. return string.Format(" (DATEADD('d',{1}, {0})) ", parameter.MemberName, parameter2.MemberName);
  290. }
  291. public override string ToInt32(MethodCallExpressionModel model)
  292. {
  293. var parameter = model.Args[0];
  294. return string.Format(" CAST({0} AS INT)", parameter.MemberName);
  295. }
  296. public override string ToInt64(MethodCallExpressionModel model)
  297. {
  298. var parameter = model.Args[0];
  299. return string.Format(" CAST({0} AS long)", parameter.MemberName);
  300. }
  301. public override string ToString(MethodCallExpressionModel model)
  302. {
  303. var parameter = model.Args[0];
  304. return string.Format(" CAST({0} AS VARCHAR)", parameter.MemberName);
  305. }
  306. public override string ToGuid(MethodCallExpressionModel model)
  307. {
  308. var parameter = model.Args[0];
  309. return string.Format(" CAST({0} AS VARCHAR)", parameter.MemberName);
  310. }
  311. public override string ToDouble(MethodCallExpressionModel model)
  312. {
  313. var parameter = model.Args[0];
  314. return string.Format(" CAST({0} AS double )", parameter.MemberName);
  315. }
  316. public override string ToBool(MethodCallExpressionModel model)
  317. {
  318. var parameter = model.Args[0];
  319. return string.Format(" CAST({0} AS boolean)", parameter.MemberName);
  320. }
  321. public override string ToDecimal(MethodCallExpressionModel model)
  322. {
  323. var parameter = model.Args[0];
  324. return string.Format(" CAST({0} AS double )", parameter.MemberName);
  325. }
  326. public override string Length(MethodCallExpressionModel model)
  327. {
  328. var parameter = model.Args[0];
  329. return string.Format(" LENGTH({0})", parameter.MemberName);
  330. }
  331. public override string MergeString(params string[] strings)
  332. {
  333. return " concat("+string.Join(",", strings).Replace("+", "") + ") ";
  334. }
  335. public override string IsNull(MethodCallExpressionModel model)
  336. {
  337. var parameter = model.Args[0];
  338. var parameter1 = model.Args[1];
  339. return string.Format("(CASE WHEN {0} IS NULL THEN {1} ELSE {0} END)", parameter.MemberName, parameter1.MemberName);
  340. }
  341. public override string GetDate()
  342. {
  343. return "now()";
  344. }
  345. public override string GetRandom()
  346. {
  347. return "now()";
  348. }
  349. public override string EqualTrue(string fieldName)
  350. {
  351. return "( " + fieldName + "=true )";
  352. }
  353. public override string GetDateString(string dateValue,string format)
  354. {
  355. return $" to_str({dateValue},'{format}') ";
  356. }
  357. }
  358. }