rds

Documentation

Index

• Constants
• type Client
  • func NewClient(dsn string) (*Client, error)
  • func (c *Client) CreateTablesFromSchema(contents []byte, pkg factset.Package) error
  • func (c *Client) DropDataFromTable(tableName string, product string) error
  • func (c *Client) DropTablesWithProductAndBundle(product string, bundle string) error
  • func (c *Client) GetPackageMetadata(pkg factset.Package) (factset.PackageMetadata, error)
  • func (c *Client) LoadMetadataTables() error
  • func (c *Client) LoadTable(filename, table string) error
  • func (c *Client) UpdateLoadedPackageVersion(packageMetadata *factset.PackageMetadata) error
  • func (c *Client) UpdateLoadedTableVersion(tableName string, version factset.PackageVersion, pkg factset.Package) error

Constants

const (
	MetadataTableCount = 2
)

Types

type Client

type Client struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

func NewClient

func NewClient(dsn string) (*Client, error)

func (*Client) CreateTablesFromSchema

func (c *Client) CreateTablesFromSchema(contents []byte, pkg factset.Package) error

CreateTablesFromSchema Takes the semicolon delimited contents of the create table file and creates the tables.

func (*Client) DropDataFromTable

func (c *Client) DropDataFromTable(tableName string, product string) error

func (*Client) DropTablesWithProductAndBundle

func (c *Client) DropTablesWithProductAndBundle(product string, bundle string) error

TODO in future we should have versioning/namespacing for our schema tables so that they are only dropped after a successful reload

func (*Client) GetPackageMetadata

func (c *Client) GetPackageMetadata(pkg factset.Package) (factset.PackageMetadata, error)

func (*Client) LoadMetadataTables

func (c *Client) LoadMetadataTables() error

func (*Client) LoadTable

func (c *Client) LoadTable(filename, table string) error

func (*Client) UpdateLoadedPackageVersion

func (c *Client) UpdateLoadedPackageVersion(packageMetadata *factset.PackageMetadata) error

func (*Client) UpdateLoadedTableVersion

func (c *Client) UpdateLoadedTableVersion(tableName string, version factset.PackageVersion, pkg factset.Package) error