databaseInfra

package

v0.1.7 Latest Latest Go to latest Published: Dec 27, 2024 License: EPL-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func MysqlCmd(cmd string) (string, error)

func PostgresqlCmd(cmd string, dbName *string) (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() ([]entity.Database, error)

func (repo DatabaseQueryRepo) ReadByName(
	name valueObject.DatabaseName,
) (entity.Database, 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 {
}

func (repo MysqlDatabaseQueryRepo) Read() ([]entity.Database, error)

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) Read() ([]entity.Database, error)

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

func (repo PostgresDatabaseQueryRepo) UserExists(
	dbUser valueObject.DatabaseUsername,
) bool