gaussdb ddl tested

backend/api/v1/rollout_service_task.go

@@ -772,6 +772,10 @@ func checkCharacterSetCollationOwner(dbType storepb.Engine, characterSet, collat
  if owner == "" {
  return errors.Errorf("database owner is required for Redshift")
  }
+ case storepb.Engine_GAUSSDB:
+ if owner == "" {
+ return errors.Errorf("database owner is required for GaussDB")
+ }
  case storepb.Engine_RISINGWAVE:
  if characterSet != "" {
  return errors.Errorf("RisingWave does not support character set, but got %s", characterSet)

backend/api/v1/sql_service_export_utils.go

@@ -188,7 +188,7 @@ func convertValueToBytesInSQL(engine storepb.Engine, value *v1pb.RowValue) []byt
 
 func escapeSQLString(engine storepb.Engine, v []byte) []byte {
  switch engine {
- case storepb.Engine_POSTGRES, storepb.Engine_REDSHIFT:
+ case storepb.Engine_POSTGRES, storepb.Engine_REDSHIFT, storepb.Engine_GAUSSDB:
  escapedStr := pq.QuoteLiteral(string(v))
  return []byte(escapedStr)
  default:

backend/plugin/parser/pg/masking.go

@@ -16,6 +16,7 @@ import (
 func init() {
  base.RegisterGetMaskedFieldsFunc(storepb.Engine_POSTGRES, GetMaskedFields)
  base.RegisterGetMaskedFieldsFunc(storepb.Engine_REDSHIFT, GetMaskedFields)
+ base.RegisterGetMaskedFieldsFunc(storepb.Engine_GAUSSDB, GetMaskedFields)
  base.RegisterGetMaskedFieldsFunc(storepb.Engine_RISINGWAVE, GetMaskedFields)
 }
 

backend/plugin/parser/pg/query.go

@@ -21,9 +21,11 @@ import (
 func init() {
  base.RegisterQueryValidator(storepb.Engine_POSTGRES, validateQuery)
  base.RegisterQueryValidator(storepb.Engine_REDSHIFT, validateQuery)
+ base.RegisterQueryValidator(storepb.Engine_GAUSSDB, validateQuery)
  base.RegisterQueryValidator(storepb.Engine_RISINGWAVE, validateQuery)
  base.RegisterExtractResourceListFunc(storepb.Engine_POSTGRES, ExtractResourceList)
  base.RegisterExtractResourceListFunc(storepb.Engine_REDSHIFT, ExtractResourceList)
+ base.RegisterExtractResourceListFunc(storepb.Engine_GAUSSDB, ExtractResourceList)
  base.RegisterExtractResourceListFunc(storepb.Engine_RISINGWAVE, ExtractResourceList)
 }
 

backend/plugin/parser/pg/query_span.go

@@ -13,6 +13,7 @@ func init() {
  base.RegisterGetQuerySpan(storepb.Engine_POSTGRES, GetQuerySpan)
  base.RegisterGetQuerySpan(storepb.Engine_REDSHIFT, GetQuerySpan)
  base.RegisterGetQuerySpan(storepb.Engine_RISINGWAVE, GetQuerySpan)
+ base.RegisterGetQuerySpan(storepb.Engine_GAUSSDB, GetQuerySpan)
 }
 
 // GetQuerySpan returns the query span for the given statement.

backend/plugin/parser/pg/split.go

@@ -15,6 +15,7 @@ import (
 func init() {
  base.RegisterSplitterFunc(storepb.Engine_POSTGRES, SplitSQL)
  base.RegisterSplitterFunc(storepb.Engine_REDSHIFT, SplitSQL)
+ base.RegisterSplitterFunc(storepb.Engine_GAUSSDB, SplitSQL)
  base.RegisterSplitterFunc(storepb.Engine_RISINGWAVE, SplitSQL)
 }
 

frontend/src/components/ColumnDataTable/index.vue

@@ -96,6 +96,7 @@ const showSensitiveColumn = computed(() => {
  engine.value === Engine.TIDB ||
  engine.value === Engine.POSTGRES ||
  engine.value === Engine.REDSHIFT ||
+ engine.value === Engine.GAUSSDB ||
  engine.value === Engine.ORACLE ||
  engine.value === Engine.SNOWFLAKE ||
  engine.value === Engine.MSSQL ||

frontend/src/components/CreateDatabasePrepForm/CreateDatabasePrepForm.vue

@@ -119,7 +119,7 @@
  <label for="charset" class="textlabel">
  {{
  selectedInstance.engine === Engine.POSTGRES ||
- selectedInstance.engine === Engine.REDSHIFT
+ selectedInstance.engine === Engine.REDSHIFT || selectedInstance.engine === Engine.GAUSSDB
  ? $t("db.encoding")
  : $t("db.character-set")
  }}</label
@@ -300,7 +300,7 @@ const requireDatabaseOwnerName = computed((): boolean => {
  if (instance.uid === String(UNKNOWN_ID)) {
  return false;
  }
- return [Engine.POSTGRES, Engine.REDSHIFT].includes(instance.engine);
+ return [Engine.POSTGRES, Engine.REDSHIFT, Engine.GAUSSDB].includes(instance.engine);
 });
 
 const validDatabaseOwnerName = computed((): boolean => {

frontend/src/components/Database/DatabaseOverviewPanel.vue

@@ -259,6 +259,7 @@ const hasSchemaProperty = computed(() => {
  databaseEngine.value === Engine.DM ||
  databaseEngine.value === Engine.MSSQL ||
  databaseEngine.value === Engine.REDSHIFT ||
+ databaseEngine.value === Engine.GAUSSDB ||
  databaseEngine.value === Engine.RISINGWAVE
  );
 });

frontend/src/components/InstanceForm/specs.ts

@@ -17,7 +17,7 @@ export const useInstanceSpecs = (
  const showDatabase = computed((): boolean => {
  return (
  (basicInfo.value.engine === Engine.POSTGRES ||
- basicInfo.value.engine === Engine.REDSHIFT) &&
+ basicInfo.value.engine === Engine.REDSHIFT || basicInfo.value.engine === Engine.GAUSSDB ) &&
  context?.editingDataSource.value?.type === DataSourceType.ADMIN
  );
  });

frontend/src/components/TableSchemaViewer.vue

@@ -112,6 +112,7 @@ const hasSchemaProperty = computed(() => {
  engine.value === Engine.DM ||
  engine.value === Engine.MSSQL ||
  engine.value === Engine.REDSHIFT ||
+ engine.value === Engine.GAUSSDB ||
  engine.value === Engine.RISINGWAVE
  );
 });

frontend/src/utils/database.ts

@@ -128,6 +128,7 @@ export const hasSchemaProperty = (databaseEngine: Engine) => {
  databaseEngine === Engine.ORACLE ||
  databaseEngine === Engine.MSSQL ||
  databaseEngine === Engine.REDSHIFT ||
+ databaseEngine === Engine.GAUSSDB ||
  databaseEngine === Engine.RISINGWAVE
  );
 };