Method QueryConn

backend/plugin/db/sqlite/sqlite.go:152–176

QueryConn queries a SQL statement in a given connection.

(ctx context.Context, conn *sql.Conn, statement string, queryContext db.QueryContext)

// QueryConn queries a SQL statement in a given connection.
func (*Driver) QueryConn(ctx context.Context, conn *sql.Conn, statement string, queryContext db.QueryContext) ([]*v1pb.QueryResult, error) {
	startTime := time.Now()
	rows, err := conn.QueryContext(ctx, statement)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	result, err := util.RowsToQueryResult(rows, util.MakeCommonValueByTypeName, util.ConvertCommonValue, queryContext.MaximumSQLResultSize)
	if err != nil {
		// nolint
		return []*v1pb.QueryResult{
			{
				Error: err.Error(),
			},
		}, nil
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	result.Latency = durationpb.New(time.Since(startTime))
	result.Statement = statement
	result.RowsCount = int64(len(result.Rows))
	return []*v1pb.QueryResult{result}, nil
}