mirror/dolt
1
0
Fork 0
mirror of https://github.com/dolthub/dolt.git synced 2026-03-09 01:56:30 -05:00
Code Issues Packages Projects Releases 144 Wiki Activity

Merge pull request #5998 from dolthub/nicktobey/connectionqueryist

Browse Source 
Add docstring to ConnectionQueryist.
This commit is contained in:
Nick Tobey
2023-05-23 10:02:56 -07:00
committed by GitHub
parent 49fb8908b3 72b6dec169
commit 84ac464f08
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
go/cmd/dolt/commands/sqlserver/sqlclient.go
View File

@@ -454,10 +454,13 @@ func secondsSince(start time.Time, end time.Time) float64 {
return timeDisplay
}
// ConnectionQueryist executes queries by connecting to a running mySql server.
type ConnectionQueryist struct {
connection *dbr.Connection
}
var _ cli.Queryist = ConnectionQueryist{}
func (c ConnectionQueryist) Query(ctx *sql.Context, query string) (sql.Schema, sql.RowIter, error) {
rows, err := c.connection.QueryContext(ctx, query)
if err != nil {
@@ -470,8 +473,6 @@ func (c ConnectionQueryist) Query(ctx *sql.Context, query string) (sql.Schema, s
return rowIter.Schema(), rowIter, nil
}
var _ cli.Queryist = ConnectionQueryist{}
// BuildConnectionStringQueryist returns a Queryist that connects to the server specified by the given server config. Presence in this
// module isn't ideal, but it's the only way to get the server config into the queryist.
func BuildConnectionStringQueryist(ctx context.Context, cwdFS filesys.Filesys, apr *argparser.ArgParseResults, port int, database string) (cli.LateBindQueryist, error) {