Skip to content

Commit

Permalink
Feedback again
Browse files Browse the repository at this point in the history
  • Loading branch information
tbantle22 committed Oct 28, 2024
1 parent ee688ce commit ac54d05
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 18 deletions.
24 changes: 10 additions & 14 deletions go/libraries/doltcore/sqle/database.go
Original file line number Diff line number Diff line change
Expand Up @@ -314,10 +314,6 @@ func (db Database) GetTableInsensitiveAsOf(ctx *sql.Context, tableName string, a
}
}

func isDoltSystemTable(tableName string) bool {
return doltdb.HasDoltPrefix(tableName) || !resolve.UseSearchPath
}

func (db Database) getTableInsensitive(ctx *sql.Context, head *doltdb.Commit, ds *dsess.DoltSession, root doltdb.RootValue, tblName string, asOf interface{}) (sql.Table, bool, error) {
lwrName := strings.ToLower(tblName)

Expand Down Expand Up @@ -426,11 +422,11 @@ func (db Database) getTableInsensitive(ctx *sql.Context, head *doltdb.Commit, ds
tname := doltdb.TableName{Name: lwrName, Schema: db.schemaName}
switch lwrName {
case doltdb.GetLogTableName(), doltdb.LogTableName:
systemTable, err := resolve.IsSystemTable(ctx, tname, root)
isDoltgresSystemTable, err := resolve.IsDoltgresSystemTable(ctx, tname, root)
if err != nil {
return nil, false, err
}
if isDoltSystemTable(lwrName) || systemTable {
if !resolve.UseSearchPath || isDoltgresSystemTable {
if head == nil {
var err error
head, err = ds.GetHeadCommit(ctx, db.RevisionQualifiedName())
Expand Down Expand Up @@ -468,11 +464,11 @@ func (db Database) getTableInsensitive(ctx *sql.Context, head *doltdb.Commit, ds
case doltdb.SchemaConflictsTableName:
dt, found = dtables.NewSchemaConflictsTable(ctx, db.RevisionQualifiedName(), db.ddb), true
case doltdb.GetBranchesTableName(), doltdb.BranchesTableName:
systemTable, err := resolve.IsSystemTable(ctx, tname, root)
isDoltgresSystemTable, err := resolve.IsDoltgresSystemTable(ctx, tname, root)
if err != nil {
return nil, false, err
}
if isDoltSystemTable(lwrName) || systemTable {
if !resolve.UseSearchPath || isDoltgresSystemTable {
dt, found = dtables.NewBranchesTable(ctx, db), true
}
case doltdb.RemoteBranchesTableName:
Expand All @@ -484,11 +480,11 @@ func (db Database) getTableInsensitive(ctx *sql.Context, head *doltdb.Commit, ds
case doltdb.CommitAncestorsTableName:
dt, found = dtables.NewCommitAncestorsTable(ctx, db.Name(), db.ddb), true
case doltdb.GetStatusTableName(), doltdb.StatusTableName:
systemTable, err := resolve.IsSystemTable(ctx, tname, root)
isDoltgresSystemTable, err := resolve.IsDoltgresSystemTable(ctx, tname, root)
if err != nil {
return nil, false, err
}
if isDoltSystemTable(lwrName) || systemTable {
if !resolve.UseSearchPath || isDoltgresSystemTable {
sess := dsess.DSessFromSess(ctx.Session)
adapter := dsess.NewSessionStateAdapter(
sess, db.RevisionQualifiedName(),
Expand All @@ -505,11 +501,11 @@ func (db Database) getTableInsensitive(ctx *sql.Context, head *doltdb.Commit, ds
case doltdb.MergeStatusTableName:
dt, found = dtables.NewMergeStatusTable(db.RevisionQualifiedName()), true
case doltdb.GetTagsTableName(), doltdb.TagsTableName:
systemTable, err := resolve.IsSystemTable(ctx, tname, root)
isDoltgresSystemTable, err := resolve.IsDoltgresSystemTable(ctx, tname, root)
if err != nil {
return nil, false, err
}
if isDoltSystemTable(lwrName) || systemTable {
if !resolve.UseSearchPath || isDoltgresSystemTable {
dt, found = dtables.NewTagsTable(ctx, db.ddb), true
}
case dtables.AccessTableName:
Expand Down Expand Up @@ -538,11 +534,11 @@ func (db Database) getTableInsensitive(ctx *sql.Context, head *doltdb.Commit, ds
dt, found = dtables.NewIgnoreTable(ctx, versionableTable), true
}
case doltdb.GetDocTableName(), doltdb.DocTableName:
systemTable, err := resolve.IsSystemTable(ctx, tname, root)
isDoltgresSystemTable, err := resolve.IsDoltgresSystemTable(ctx, tname, root)
if err != nil {
return nil, false, err
}
if isDoltSystemTable(lwrName) || systemTable {
if !resolve.UseSearchPath || isDoltgresSystemTable {
if resolve.UseSearchPath && lwrName == doltdb.DocTableName {
db.schemaName = "dolt"
}
Expand Down
8 changes: 4 additions & 4 deletions go/libraries/doltcore/sqle/resolve/search_path.go
Original file line number Diff line number Diff line change
Expand Up @@ -79,12 +79,12 @@ func FirstExistingSchemaOnSearchPath(ctx *sql.Context, root doltdb.RootValue) (s
return schemaName, nil
}

// IsSystemTable returns whether a table is a system table or not
func IsSystemTable(ctx *sql.Context, tableName doltdb.TableName, root doltdb.RootValue) (bool, error) {
if tableName.Schema == "dolt" {
// IsDoltgresSystemTable returns whether a table is a doltgres system table or not
func IsDoltgresSystemTable(ctx *sql.Context, tableName doltdb.TableName, root doltdb.RootValue) (bool, error) {
if tableName.Schema == "dolt" || doltdb.HasDoltPrefix(tableName.Name) {
return true, nil
}
if tableName.Schema != "" {
if !UseSearchPath || tableName.Schema != "" {
return false, nil
}

Expand Down

0 comments on commit ac54d05

Please sign in to comment.