KdbndpExpressionContext.cs 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474
  1. using System;
  2. using System.Linq;
  3. namespace SqlSugar
  4. {
  5. public class KdbndpExpressionContext : ExpressionContext, ILambdaExpressions
  6. {
  7. public SqlSugarProvider Context { get; set; }
  8. public KdbndpExpressionContext()
  9. {
  10. base.DbMehtods = new KdbndpMethod();
  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.ToUpper(IsUpper) + SqlTranslationRight;
  29. }
  30. public override string GetTranslationTableName(string entityName, bool isMapping = true)
  31. {
  32. Check.ArgumentNullException(entityName, string.Format(ErrorMessage.ObjNotExist, "Table Name"));
  33. if (IsTranslationText(entityName)) return entityName;
  34. isMapping = isMapping && this.MappingTables.HasValue();
  35. var isComplex = entityName.Contains(UtilConstants.Dot);
  36. if (isMapping && isComplex)
  37. {
  38. var columnInfo = entityName.Split(UtilConstants.DotChar);
  39. var mappingInfo = this.MappingTables.FirstOrDefault(it => it.EntityName.Equals(columnInfo.Last(), StringComparison.CurrentCultureIgnoreCase));
  40. if (mappingInfo != null)
  41. {
  42. columnInfo[columnInfo.Length - 1] = mappingInfo.EntityName;
  43. }
  44. return string.Join(UtilConstants.Dot, columnInfo.Select(it => GetTranslationText(it)));
  45. }
  46. else if (isMapping)
  47. {
  48. var mappingInfo = this.MappingTables.FirstOrDefault(it => it.EntityName.Equals(entityName, StringComparison.CurrentCultureIgnoreCase));
  49. return SqlTranslationLeft + (mappingInfo == null ? entityName : mappingInfo.DbTableName).ToUpper(IsUpper) + SqlTranslationRight;
  50. }
  51. else if (isComplex)
  52. {
  53. return string.Join(UtilConstants.Dot, entityName.Split(UtilConstants.DotChar).Select(it => GetTranslationText(it)));
  54. }
  55. else
  56. {
  57. return GetTranslationText(entityName);
  58. }
  59. }
  60. public override string GetTranslationColumnName(string columnName)
  61. {
  62. Check.ArgumentNullException(columnName, string.Format(ErrorMessage.ObjNotExist, "Column Name"));
  63. if (columnName.Substring(0, 1) == this.SqlParameterKeyWord)
  64. {
  65. return columnName;
  66. }
  67. if (IsTranslationText(columnName)) return columnName;
  68. if (columnName.Contains(UtilConstants.Dot))
  69. {
  70. return string.Join(UtilConstants.Dot, columnName.Split(UtilConstants.DotChar).Select(it => GetTranslationText(it)));
  71. }
  72. else
  73. {
  74. return GetTranslationText(columnName);
  75. }
  76. }
  77. public override string GetDbColumnName(string entityName, string propertyName)
  78. {
  79. if (this.MappingColumns.HasValue())
  80. {
  81. var mappingInfo = this.MappingColumns.SingleOrDefault(it => it.EntityName == entityName && it.PropertyName == propertyName);
  82. return (mappingInfo == null ? propertyName : mappingInfo.DbColumnName).ToUpper(IsUpper);
  83. }
  84. else
  85. {
  86. return propertyName.ToUpper(IsUpper);
  87. }
  88. }
  89. public bool IsUpper
  90. {
  91. get
  92. {
  93. if (this.SugarContext?.Context?.Context?.CurrentConnectionConfig?.MoreSettings == null)
  94. {
  95. return true;
  96. }
  97. else
  98. {
  99. return this.SugarContext?.Context?.Context?.CurrentConnectionConfig?.MoreSettings.IsAutoToUpper == true;
  100. }
  101. }
  102. }
  103. }
  104. public class KdbndpMethod : DefaultDbMethod, IDbMethods
  105. {
  106. public override string CharIndexNew(MethodCallExpressionModel model)
  107. {
  108. return string.Format(" (strpos ({0},{1}))", model.Args[0].MemberName, model.Args[1].MemberName);
  109. }
  110. public override string CharIndex(MethodCallExpressionModel model)
  111. {
  112. return string.Format(" (strpos ({1},{0})-1)", model.Args[0].MemberName, model.Args[1].MemberName);
  113. }
  114. public override string TrueValue()
  115. {
  116. return "true";
  117. }
  118. public override string FalseValue()
  119. {
  120. return "false";
  121. }
  122. public override string DateDiff(MethodCallExpressionModel model)
  123. {
  124. var parameter = (DateType)(Enum.Parse(typeof(DateType), model.Args[0].MemberValue.ObjToString()));
  125. var begin = model.Args[1].MemberName;
  126. var end = model.Args[2].MemberName;
  127. switch (parameter)
  128. {
  129. case DateType.Year:
  130. return $" ( DATE_PART('Year', {end} ) - DATE_PART('Year', {begin}) )";
  131. case DateType.Month:
  132. return $" ( ( DATE_PART('Year', {end} ) - DATE_PART('Year', {begin}) ) * 12 + (DATE_PART('month', {end}) - DATE_PART('month', {begin})) )";
  133. case DateType.Day:
  134. return $" ( DATE_PART('day', {end} - {begin}) )";
  135. case DateType.Hour:
  136. return $" ( ( DATE_PART('day', {end} - {begin}) ) * 24 + DATE_PART('hour', {end} - {begin} ) )";
  137. case DateType.Minute:
  138. return $" ( ( ( DATE_PART('day', {end} - {begin}) ) * 24 + DATE_PART('hour', {end} - {begin} ) ) * 60 + DATE_PART('minute', {end} - {begin} ) )";
  139. case DateType.Second:
  140. return $" ( ( ( DATE_PART('day', {end} - {begin}) ) * 24 + DATE_PART('hour', {end} - {begin} ) ) * 60 + DATE_PART('minute', {end} - {begin} ) ) * 60 + DATE_PART('minute', {end} - {begin} )";
  141. case DateType.Millisecond:
  142. break;
  143. default:
  144. break;
  145. }
  146. throw new Exception(parameter + " datediff no support");
  147. }
  148. public override string IIF(MethodCallExpressionModel model)
  149. {
  150. var parameter = model.Args[0];
  151. var parameter2 = model.Args[1];
  152. var parameter3 = model.Args[2];
  153. if (parameter.Type == UtilConstants.BoolType)
  154. {
  155. parameter.MemberName = parameter.MemberName.ToString().Replace("=1", "=true");
  156. parameter2.MemberName = false;
  157. parameter3.MemberName = true;
  158. }
  159. return string.Format("( CASE WHEN {0} THEN {1} ELSE {2} END )", parameter.MemberName, parameter2.MemberName, parameter3.MemberName);
  160. }
  161. public override string DateValue(MethodCallExpressionModel model)
  162. {
  163. var parameter = model.Args[0];
  164. var parameter2 = model.Args[1];
  165. var format = "dd";
  166. if (parameter2.MemberValue.ObjToString() == DateType.Year.ToString())
  167. {
  168. format = "yyyy";
  169. }
  170. if (parameter2.MemberValue.ObjToString() == DateType.Month.ToString())
  171. {
  172. format = "MM";
  173. }
  174. if (parameter2.MemberValue.ObjToString() == DateType.Day.ToString())
  175. {
  176. format = "dd";
  177. }
  178. if (parameter2.MemberValue.ObjToString() == DateType.Hour.ToString())
  179. {
  180. format = "hh24";
  181. }
  182. if (parameter2.MemberValue.ObjToString() == DateType.Minute.ToString())
  183. {
  184. format = "mi";
  185. }
  186. if (parameter2.MemberValue.ObjToString() == DateType.Second.ToString())
  187. {
  188. format = "ss";
  189. }
  190. if (parameter2.MemberValue.ObjToString() == DateType.Millisecond.ToString())
  191. {
  192. format = "ms";
  193. }
  194. if (parameter2.MemberValue.ObjToString() == DateType.Weekday.ToString())
  195. {
  196. return $" extract(DOW FROM cast({parameter.MemberName} as TIMESTAMP)) ";
  197. }
  198. return string.Format(" cast( to_char({1},'{0}')as integer ) ", format, parameter.MemberName);
  199. }
  200. public override string Contains(MethodCallExpressionModel model)
  201. {
  202. var parameter = model.Args[0];
  203. var parameter2 = model.Args[1];
  204. return string.Format(" ({0} like concat('%',{1},'%')) ", parameter.MemberName, parameter2.MemberName);
  205. }
  206. public override string StartsWith(MethodCallExpressionModel model)
  207. {
  208. var parameter = model.Args[0];
  209. var parameter2 = model.Args[1];
  210. return string.Format(" ({0} like concat({1},'%')) ", parameter.MemberName, parameter2.MemberName);
  211. }
  212. public override string EndsWith(MethodCallExpressionModel model)
  213. {
  214. var parameter = model.Args[0];
  215. var parameter2 = model.Args[1];
  216. return string.Format(" ({0} like concat('%',{1}))", parameter.MemberName, parameter2.MemberName);
  217. }
  218. public override string DateIsSameDay(MethodCallExpressionModel model)
  219. {
  220. var parameter = model.Args[0];
  221. var parameter2 = model.Args[1];
  222. return string.Format(" ( to_char({0},'yyyy-MM-dd')=to_char({1},'yyyy-MM-dd') ) ", parameter.MemberName, parameter2.MemberName); ;
  223. }
  224. public override string HasValue(MethodCallExpressionModel model)
  225. {
  226. var parameter = model.Args[0];
  227. return string.Format("( {0} IS NOT NULL )", parameter.MemberName);
  228. }
  229. public override string DateIsSameByType(MethodCallExpressionModel model)
  230. {
  231. var parameter = model.Args[0];
  232. var parameter2 = model.Args[1];
  233. var parameter3 = model.Args[2];
  234. DateType dateType = (DateType)parameter3.MemberValue;
  235. var format = "yyyy-MM-dd";
  236. if (dateType == DateType.Quarter)
  237. {
  238. return string.Format(" (date_trunc('quarter',{0})=date_trunc('quarter',{1}) ) ", parameter.MemberName, parameter2.MemberName, format);
  239. }
  240. switch (dateType)
  241. {
  242. case DateType.Year:
  243. format = "yyyy";
  244. break;
  245. case DateType.Month:
  246. format = "yyyy-MM";
  247. break;
  248. case DateType.Day:
  249. break;
  250. case DateType.Hour:
  251. format = "yyyy-MM-dd HH";
  252. break;
  253. case DateType.Second:
  254. format = "yyyy-MM-dd HH:mm:ss";
  255. break;
  256. case DateType.Minute:
  257. format = "yyyy-MM-dd HH:mm";
  258. break;
  259. case DateType.Millisecond:
  260. format = "yyyy-MM-dd HH:mm.ms";
  261. break;
  262. default:
  263. break;
  264. }
  265. return string.Format(" ( to_char({0},'{2}')=to_char({1},'{2}') ) ", parameter.MemberName, parameter2.MemberName, format);
  266. }
  267. public override string ToDate(MethodCallExpressionModel model)
  268. {
  269. var parameter = model.Args[0];
  270. return string.Format(" CAST({0} AS timestamp)", parameter.MemberName);
  271. }
  272. public override string DateAddByType(MethodCallExpressionModel model)
  273. {
  274. var parameter = model.Args[0];
  275. var parameter2 = model.Args[1];
  276. var parameter3 = model.Args[2];
  277. return string.Format(" ({1} + ({2}||'{0}')::INTERVAL) ", parameter3.MemberValue, parameter.MemberName, parameter2.MemberName);
  278. }
  279. public override string DateAddDay(MethodCallExpressionModel model)
  280. {
  281. var parameter = model.Args[0];
  282. var parameter2 = model.Args[1];
  283. return string.Format(" ({0} + ({1}||'day')::INTERVAL) ", parameter.MemberName, parameter2.MemberName);
  284. }
  285. public override string ToInt32(MethodCallExpressionModel model)
  286. {
  287. var parameter = model.Args[0];
  288. return string.Format(" CAST({0} AS INT4)", parameter.MemberName);
  289. }
  290. public override string ToInt64(MethodCallExpressionModel model)
  291. {
  292. var parameter = model.Args[0];
  293. return string.Format(" CAST({0} AS INT8)", parameter.MemberName);
  294. }
  295. public override string ToString(MethodCallExpressionModel model)
  296. {
  297. var parameter = model.Args[0];
  298. return string.Format(" CAST({0} AS VARCHAR)", parameter.MemberName);
  299. }
  300. public override string ToGuid(MethodCallExpressionModel model)
  301. {
  302. var parameter = model.Args[0];
  303. return string.Format(" CAST({0} AS UUID)", parameter.MemberName);
  304. }
  305. public override string ToDouble(MethodCallExpressionModel model)
  306. {
  307. var parameter = model.Args[0];
  308. return string.Format(" CAST({0} AS DECIMAL(18,4))", parameter.MemberName);
  309. }
  310. public override string ToBool(MethodCallExpressionModel model)
  311. {
  312. var parameter = model.Args[0];
  313. return string.Format(" CAST({0} AS boolean)", parameter.MemberName);
  314. }
  315. public override string ToDecimal(MethodCallExpressionModel model)
  316. {
  317. var parameter = model.Args[0];
  318. return string.Format(" CAST({0} AS DECIMAL(18,4))", parameter.MemberName);
  319. }
  320. public override string Length(MethodCallExpressionModel model)
  321. {
  322. var parameter = model.Args[0];
  323. return string.Format(" LENGTH({0})", parameter.MemberName);
  324. }
  325. public override string MergeString(params string[] strings)
  326. {
  327. var key = Guid.NewGuid() + "";
  328. return " concat(" + string.Join(",", strings.Select(it => it?.Replace("+", key))).Replace("+", "").Replace(key, "+") + ") ";
  329. }
  330. public override string IsNull(MethodCallExpressionModel model)
  331. {
  332. var parameter = model.Args[0];
  333. var parameter1 = model.Args[1];
  334. return string.Format("(CASE WHEN {0} IS NULL THEN {1} ELSE {0} END)", parameter.MemberName, parameter1.MemberName);
  335. }
  336. public override string GetDate()
  337. {
  338. return "NOW()";
  339. }
  340. public override string GetRandom()
  341. {
  342. return "RANDOM()";
  343. }
  344. public override string EqualTrue(string fieldName)
  345. {
  346. return "( " + fieldName + "=true )";
  347. }
  348. public override string JsonField(MethodCallExpressionModel model)
  349. {
  350. var parameter = model.Args[0];
  351. var parameter1 = model.Args[1];
  352. //var parameter2 = model.Args[2];
  353. //var parameter3= model.Args[3];
  354. var result = GetJson(parameter.MemberName, parameter1.MemberName, model.Args.Count() == 2);
  355. if (model.Args.Count > 2)
  356. {
  357. result = GetJson(result, model.Args[2].MemberName, model.Args.Count() == 3);
  358. }
  359. if (model.Args.Count > 3)
  360. {
  361. result = GetJson(result, model.Args[3].MemberName, model.Args.Count() == 4);
  362. }
  363. if (model.Args.Count > 4)
  364. {
  365. result = GetJson(result, model.Args[4].MemberName, model.Args.Count() == 5);
  366. }
  367. if (model.Args.Count > 5)
  368. {
  369. result = GetJson(result, model.Args[5].MemberName, model.Args.Count() == 6);
  370. }
  371. return result;
  372. }
  373. public override string JsonContainsFieldName(MethodCallExpressionModel model)
  374. {
  375. var parameter = model.Args[0];
  376. var parameter1 = model.Args[1];
  377. return $"({parameter.MemberName}::jsonb ?{parameter1.MemberName})";
  378. }
  379. private string GetJson(object memberName1, object memberName2, bool isLast)
  380. {
  381. if (isLast)
  382. {
  383. return $"({memberName1}::json->>{memberName2})";
  384. }
  385. else
  386. {
  387. return $"({memberName1}->{memberName2})";
  388. }
  389. }
  390. public override string JsonArrayLength(MethodCallExpressionModel model)
  391. {
  392. var parameter = model.Args[0];
  393. //var parameter1 = model.Args[1];
  394. return $" json_array_length({parameter.MemberName}::json) ";
  395. }
  396. public override string JsonParse(MethodCallExpressionModel model)
  397. {
  398. var parameter = model.Args[0];
  399. //var parameter1 = model.Args[1];
  400. return $" ({parameter.MemberName}::json) ";
  401. }
  402. public override string JsonArrayAny(MethodCallExpressionModel model)
  403. {
  404. if (UtilMethods.IsNumber(model.Args[1].MemberValue.GetType().Name))
  405. {
  406. return $"{model.Args[0].MemberName}::jsonb @> '[{model.Args[1].MemberValue.ObjToStringNoTrim().ToSqlFilter()}]'::jsonb";
  407. }
  408. else
  409. {
  410. return $"{model.Args[0].MemberName}::jsonb @> '[\"{model.Args[1].MemberValue}\"]'::jsonb";
  411. }
  412. }
  413. public override string JsonListObjectAny(MethodCallExpressionModel model)
  414. {
  415. if (UtilMethods.IsNumber(model.Args[2].MemberValue.GetType().Name))
  416. {
  417. return $"{model.Args[0].MemberName}::jsonb @> '[{{\"{model.Args[1].MemberValue}\":{model.Args[2].MemberValue}}}]'::jsonb";
  418. }
  419. else
  420. {
  421. return $"{model.Args[0].MemberName}::jsonb @> '[{{\"{model.Args[1].MemberValue}\":\"{model.Args[2].MemberValue.ObjToStringNoTrim().ToSqlFilter()}\"}}]'::jsonb";
  422. }
  423. }
  424. public override string GetDateString(string dateValue, string formatString)
  425. {
  426. if (formatString.HasValue() && formatString.Contains("hh:mm"))
  427. {
  428. formatString = formatString.Replace("hh:mm", "hh:mi");
  429. }
  430. else if (formatString.HasValue() && formatString.Contains("hhmm"))
  431. {
  432. formatString = formatString.Replace("hhmm", "hhmi");
  433. }
  434. else if (formatString.HasValue() && formatString.Contains("HH:mm"))
  435. {
  436. formatString = formatString.Replace("HH:mm", "HH:mi");
  437. }
  438. else if (formatString.HasValue() && formatString.Contains("HHmm"))
  439. {
  440. formatString = formatString.Replace("HHmm", "HHmi");
  441. }
  442. if (formatString.Contains("HH"))
  443. {
  444. formatString = formatString.Replace("HH", "hh24");
  445. }
  446. return $" to_char({dateValue},'{formatString}') ";
  447. }
  448. }
  449. }