sql

Sep 13, 2024

Changes in this version

+ type DatabaseName = string

+ type DatabaseServer struct

+ ConnectionString string

+ DatabaseName string

+ ResourceRegister *resources.ResourceRegister[resourcespb.SqlDatabaseResource]

+ Status string

+ type DatabaseStatus string

+ const DatabaseStatusActive

+ const DatabaseStatusApplyingMigrations

+ const DatabaseStatusBuildingMigrations

+ const DatabaseStatusError

+ const DatabaseStatusStarting

type LocalSqlServer

+ State State

+ func (l *LocalSqlServer) BuildAndRunMigrations(fs afero.Fs, databasesToMigrate map[string]*resourcespb.SqlDatabaseResource) error

+ func (l *LocalSqlServer) GetState() State

+ func (l *LocalSqlServer) Publish(state State)

+ func (l *LocalSqlServer) RegisterDatabases(lrs resources.LocalResourcesState)

+ func (l *LocalSqlServer) SubscribeToState(subscriberFunction func(State))

+ type MigrationRunner = func(fs afero.Fs, servers map[string]*DatabaseServer, ...) error

+ type State = map[DatabaseName]*DatabaseServer

Aug 15, 2024

Changes in this version

+ func SQLSplit(sql string) []string

Aug 2, 2024

Changes in this version

type LocalSqlServer

+ func (l *LocalSqlServer) Query(ctx context.Context, connectionString string, query string) ([]*orderedmap.OrderedMap[string, any], error)

Jun 11, 2024

Changes in this version

+ type LocalSqlServer struct

+ func NewLocalSqlServer(projectName string) (*LocalSqlServer, error)

+ func (l *LocalSqlServer) ConnectionString(ctx context.Context, req *sqlpb.SqlConnectionStringRequest) (*sqlpb.SqlConnectionStringResponse, error)

+ func (l *LocalSqlServer) Stop() error