PostgreSQLBuilder.cs 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128
  1. using System;
  2. using System.Linq;
  3. using System.Text.RegularExpressions;
  4. namespace SqlSugar
  5. {
  6. public class PostgreSQLBuilder : SqlBuilderProvider
  7. {
  8. public override string SqlTranslationLeft
  9. {
  10. get
  11. {
  12. return "\"";
  13. }
  14. }
  15. public override string SqlTranslationRight
  16. {
  17. get
  18. {
  19. return "\"";
  20. }
  21. }
  22. public override string SqlDateNow
  23. {
  24. get
  25. {
  26. return "CURRENT_TIMESTAMP";
  27. }
  28. }
  29. public override string FullSqlDateNow
  30. {
  31. get
  32. {
  33. return "select CURRENT_TIMESTAMP";
  34. }
  35. }
  36. public bool isAutoToLower
  37. {
  38. get
  39. {
  40. if (this.Context.CurrentConnectionConfig.MoreSettings == null) return true;
  41. return this.Context.CurrentConnectionConfig.MoreSettings.PgSqlIsAutoToLower;
  42. }
  43. }
  44. public override string GetTranslationColumnName(string propertyName)
  45. {
  46. if (propertyName.Contains(".")&& !propertyName.Contains(SqlTranslationLeft))
  47. {
  48. return string.Join(".", propertyName.Split('.').Select(it => $"{SqlTranslationLeft}{it.ToLower(isAutoToLower)}{SqlTranslationRight}"));
  49. }
  50. if (propertyName.Contains(SqlTranslationLeft)) return propertyName;
  51. else
  52. return SqlTranslationLeft + propertyName.ToLower(isAutoToLower) + SqlTranslationRight;
  53. }
  54. //public override string GetNoTranslationColumnName(string name)
  55. //{
  56. // return name.TrimEnd(Convert.ToChar(SqlTranslationRight)).TrimStart(Convert.ToChar(SqlTranslationLeft)).ToLower();
  57. //}
  58. public override string GetTranslationColumnName(string entityName, string propertyName)
  59. {
  60. Check.ArgumentNullException(entityName, string.Format(ErrorMessage.ObjNotExist, "Table Name"));
  61. Check.ArgumentNullException(propertyName, string.Format(ErrorMessage.ObjNotExist, "Column Name"));
  62. var context = this.Context;
  63. var mappingInfo = context
  64. .MappingColumns
  65. .FirstOrDefault(it =>
  66. it.EntityName.Equals(entityName, StringComparison.CurrentCultureIgnoreCase) &&
  67. it.PropertyName.Equals(propertyName, StringComparison.CurrentCultureIgnoreCase));
  68. return (mappingInfo == null ? SqlTranslationLeft + propertyName.ToLower(isAutoToLower) + SqlTranslationRight : SqlTranslationLeft + mappingInfo.DbColumnName.ToLower(isAutoToLower) + SqlTranslationRight);
  69. }
  70. public override string GetTranslationTableName(string name)
  71. {
  72. Check.ArgumentNullException(name, string.Format(ErrorMessage.ObjNotExist, "Table Name"));
  73. var context = this.Context;
  74. var mappingInfo = context
  75. .MappingTables
  76. .FirstOrDefault(it => it.EntityName.Equals(name, StringComparison.CurrentCultureIgnoreCase));
  77. if (mappingInfo == null && name.Contains(".") && name.Contains("\""))
  78. {
  79. return name;
  80. }
  81. name = (mappingInfo == null ? name : mappingInfo.DbTableName);
  82. if (name.Contains(".")&& !name.Contains("(")&&!name.Contains("\".\""))
  83. {
  84. return string.Join(".", name.ToLower(isAutoToLower).Split('.').Select(it => SqlTranslationLeft + it + SqlTranslationRight));
  85. }
  86. else if (name.Contains("("))
  87. {
  88. return name;
  89. }
  90. else if (name.Contains(SqlTranslationLeft) && name.Contains(SqlTranslationRight))
  91. {
  92. return name;
  93. }
  94. else
  95. {
  96. return SqlTranslationLeft + name.ToLower(isAutoToLower).TrimEnd('"').TrimStart('"') + SqlTranslationRight;
  97. }
  98. }
  99. public override string GetUnionFomatSql(string sql)
  100. {
  101. return " ( " + sql + " ) ";
  102. }
  103. public override Type GetNullType(string tableName, string columnName)
  104. {
  105. if (tableName != null)
  106. tableName = tableName.Trim();
  107. var columnInfo=this.Context.DbMaintenance.GetColumnInfosByTableName(tableName).FirstOrDefault(z => z.DbColumnName.EqualCase(columnName));
  108. if (columnInfo != null)
  109. {
  110. var cTypeName=this.Context.Ado.DbBind.GetCsharpTypeNameByDbTypeName(columnInfo.DataType);
  111. var value=UtilMethods.GetTypeByTypeName(cTypeName);
  112. if (value != null)
  113. {
  114. var key = "GetNullType_" + tableName + columnName;
  115. return new ReflectionInoCacheService().GetOrCreate(key, () => value);
  116. }
  117. }
  118. return null;
  119. }
  120. }
  121. }