databaseInfra

package

v0.2.7 Latest Latest Go to latest Published: Oct 3, 2025 License: EPL-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func MysqlCmd(cmd string) (string, error)

func PostgresqlCmd(cmd string, dbName *valueObject.DatabaseName) (string, error)

type DatabaseCmdRepo struct {
	// contains filtered or unexported fields
}

func NewDatabaseCmdRepo(
	dbType valueObject.DatabaseType,
) *DatabaseCmdRepo

func (repo DatabaseCmdRepo) Create(dbName valueObject.DatabaseName) error

func (repo DatabaseCmdRepo) CreateUser(createDatabaseUser dto.CreateDatabaseUser) error

func (repo DatabaseCmdRepo) Delete(dbName valueObject.DatabaseName) error

func (repo DatabaseCmdRepo) DeleteUser(
	dbName valueObject.DatabaseName,
	dbUser valueObject.DatabaseUsername,
) error

type DatabaseQueryRepo struct {
	// contains filtered or unexported fields
}

func NewDatabaseQueryRepo(
	dbType valueObject.DatabaseType,
) *DatabaseQueryRepo

func (repo DatabaseQueryRepo) Read(
	requestDto dto.ReadDatabasesRequest,
) (responseDto dto.ReadDatabasesResponse, err error)

func (repo DatabaseQueryRepo) ReadFirst(
	requestDto dto.ReadDatabasesRequest,
) (database entity.Database, err error)

type MysqlDatabaseCmdRepo struct {
}

func (repo MysqlDatabaseCmdRepo) Create(dbName valueObject.DatabaseName) error

func (repo MysqlDatabaseCmdRepo) CreateUser(createDatabaseUser dto.CreateDatabaseUser) error

func (repo MysqlDatabaseCmdRepo) Delete(dbName valueObject.DatabaseName) error

func (repo MysqlDatabaseCmdRepo) DeleteUser(
	dbName valueObject.DatabaseName,
	dbUser valueObject.DatabaseUsername,
) error

type MysqlDatabaseQueryRepo struct {
}

type PostgresDatabaseCmdRepo struct {
}

func (repo PostgresDatabaseCmdRepo) Create(dbName valueObject.DatabaseName) error

func (repo PostgresDatabaseCmdRepo) CreateUser(
	createDatabaseUser dto.CreateDatabaseUser,
) error

func (repo PostgresDatabaseCmdRepo) Delete(dbName valueObject.DatabaseName) error

func (repo PostgresDatabaseCmdRepo) DeleteUser(
	dbName valueObject.DatabaseName,
	dbUser valueObject.DatabaseUsername,
) error

type PostgresDatabaseQueryRepo struct {
}

func (repo PostgresDatabaseQueryRepo) ReadDatabaseNamesByUser(
	dbUsername valueObject.DatabaseUsername,
) ([]valueObject.DatabaseName, error)

func (repo PostgresDatabaseQueryRepo) UserExists(dbUsername valueObject.DatabaseUsername) bool