Function listOracleSchema

api/handler/v2/database.go:119–167

(logger hclog.Logger, reqParam *models.ListDatabaseSchemasReqV2)

}

func listOracleSchema(logger hclog.Logger, reqParam *models.ListDatabaseSchemasReqV2) ([]*models.SchemaItem, error) {
	if reqParam.IsPasswordEncrypted && reqParam.Password != "" {
		realPwd, err := handler.DecryptPassword(reqParam.Password, g.RsaPrivateKey)
		if nil != err {
			return nil, err
		}
		reqParam.Password = realPwd
	}
	oracleDb, err := config.NewDB(context.TODO(), &config.OracleConfig{
		User:        reqParam.User,
		Password:    reqParam.Password,
		Host:        reqParam.Host,
		Port:        reqParam.Port,
		ServiceName: reqParam.ServiceName,
	})
	if err != nil {
		return nil, err
	}
	defer oracleDb.Close()

	logger.Info("get schemas and tables from oracle")

	schemas, err := oracleDb.GetSchemas()
	if err != nil {
		return nil, fmt.Errorf("get oracle schemas err : %v", err)
	}
	replicateDoDb := make([]*models.SchemaItem, 0)
	for _, schema := range schemas {
		tableNames, err := oracleDb.GetTables(schema)
		if err != nil {
			return nil, fmt.Errorf("get oracle schema %v tables failed: %v", schema, err)
		}
		tables := []*models.TableItem{}
		for _, tableName := range tableNames {
			tb := &models.TableItem{
				TableName: tableName,
			}
			tables = append(tables, tb)
		}

		schema := &models.SchemaItem{
			SchemaName: schema,
			Tables:     tables,
		}
		replicateDoDb = append(replicateDoDb, schema)
	}
	return replicateDoDb, nil

}

// @Id ListDatabaseColumnsV2
// @Description list columns of database source instance.