database_provider.go at v0.41.7 - STRLCPY/dolt

ROOT /

go /

sqle /

database_provider.go

1110 lines | ISO-8859-1 | 32 KB

Blame Outline

Outline

dbRevisionDelimiter

DoltDatabaseProvider

dbLocations : map[string]filesys.Filesys

databases : map[string]sql.Database

functions : map[string]sql.Function

externalProcedures : sql.ExternalStoredProcedureRegistry

mu : *sync.RWMutex

defaultBranch : string

fs : filesys.Filesys

remoteDialer : dbfactory.GRPCDialProvider

dbFactoryUrl : string

WithFunctions(fns []sql.Function) : DoltDatabaseProvider

WithDbFactoryUrl(url string) : DoltDatabaseProvider

WithRemoteDialer(provider dbfactory.GRPCDialProvider) : DoltDatabaseProvider

FileSystem() : filesys.Filesys

FileSystemForDatabase(dbname string) : (filesys.Filesys, error)

Database(ctx *sql.Context, name string) : (db sql.Database, err error)

attemptCloneReplica(ctx *sql.Context, dbName string) : error

HasDatabase(ctx *sql.Context, name string) : bool

AllDatabases(ctx *sql.Context) : (all []sql.Database)

GetRemoteDB(ctx *sql.Context, srcDB *doltdb.DoltDB, r env.Remote, withCaching bool) : (*doltdb.DoltDB, error)

CreateDatabase(ctx *sql.Context, name string) : error

configureReplication(ctx *sql.Context, name string, newEnv *env.DoltEnv) : error

CloneDatabaseFromRemote(ctx *sql.Context, dbName, branch, remoteName, remoteUrl string, remoteParams map[string]string) : error

cloneDatabaseFromRemote( ctx *sql.Context, dbName, remoteName, branch, remoteUrl string, remoteParams map[string]string, ) : error

DropDatabase(ctx *sql.Context, name string) : error

databaseForRevision(ctx *sql.Context, revDB string) : (sql.Database, dsess.InitialDbState, bool, error)

databaseForClone(ctx *sql.Context, revDB string) : (sql.Database, error)

resolveAncestorSpec(ctx *sql.Context, revSpec string, ddb *doltdb.DoltDB) : (string, error)

RevisionDbState(ctx *sql.Context, revDB string) : (dsess.InitialDbState, error)

Function(_ *sql.Context, name string) : (sql.Function, error)

Register(d sql.ExternalStoredProcedureDetails)

ExternalStoredProcedure(_ *sql.Context, name string, numOfParams int) : (*sql.ExternalStoredProcedureDetails, error)

ExternalStoredProcedures(_ *sql.Context, name string) : ([]sql.ExternalStoredProcedureDetails, error)

TableFunction(_ *sql.Context, name string) : (sql.TableFunction, error)

GetRevisionForRevisionDatabase(ctx *sql.Context, dbName string) : (string, string, error)

IsRevisionDatabase(ctx *sql.Context, dbName string) : (bool, error)

_ : sql.DatabaseProvider

_ : sql.FunctionProvider

_ : sql.MutableDatabaseProvider

_ : sql.ExternalStoredProcedureProvider

_ : sql.TableFunctionProvider

_ : dsess.DoltDatabaseProvider

NewDoltDatabaseProvider(defaultBranch string, fs filesys.Filesys) : (DoltDatabaseProvider, error)

NewDoltDatabaseProviderWithDatabase(defaultBranch string, fs filesys.Filesys, database sql.Database, dbLocation filesys.Filesys) : (DoltDatabaseProvider, error)

NewDoltDatabaseProviderWithDatabases(defaultBranch string, fs filesys.Filesys, databases []sql.Database, locations []filesys.Filesys) : (DoltDatabaseProvider, error)

getRemoteDb(ctx *sql.Context, r env.Remote, dialer dbfactory.GRPCDialProvider) : (*doltdb.DoltDB, error)

readReplicationActive(ctx *sql.Context) : bool

switchAndFetchReplicaHead(ctx *sql.Context, branch string, db ReadReplicaDatabase) : error

isBranch(ctx context.Context, db SqlDatabase, branchName string, dialer dbfactory.GRPCDialProvider) : (bool, error)

isTag(ctx context.Context, db SqlDatabase, tagName string, dialer dbfactory.GRPCDialProvider) : (bool, error)

dbRevisionForBranch(ctx context.Context, srcDb SqlDatabase, revSpec string) : (SqlDatabase, dsess.InitialDbState, error)

dbRevisionForTag(ctx context.Context, srcDb Database, revSpec string) : (ReadOnlyDatabase, dsess.InitialDbState, error)

dbRevisionForCommit(ctx context.Context, srcDb Database, revSpec string) : (ReadOnlyDatabase, dsess.InitialDbState, error)

staticRepoState

branch : ref.DoltRef

env.RepoStateWriter

env.RepoStateReader

CWBHeadRef() : ref.DoltRef

formatDbMapKeyName(name string) : string

Please wait...

Page is in error, reload to recover