Method SyncDBSchema

backend/plugin/db/hive/sync.go:42–56

(ctx context.Context)

}

func (d *Driver) SyncDBSchema(ctx context.Context) (*storepb.DatabaseSchemaMetadata, error) {
	dbName := d.config.ConnectionContext.DatabaseName
	if dbName == "" {
		dbName = "default"
	}

	schemaMetadata, err := d.getDatabaseInfoByName(ctx, dbName)
	if err != nil {
		return nil, errors.Wrapf(err, "failed to get info from database %s", dbName)
	}
	return &storepb.DatabaseSchemaMetadata{
		Name:    dbName,
		Schemas: []*storepb.SchemaMetadata{schemaMetadata},
	}, nil
}

func (d *Driver) getVersion(ctx context.Context) (string, error) {
	result, err := d.queryStatementWithLimit(ctx, "SELECT VERSION()", 0)