sql

package
Version: v0.0.0-...-45692f4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 1, 2015 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateSQLGTFSRepository

func CreateSQLGTFSRepository(driver *database.Driver) database.GTFSRepository

Types

type SQLAgenciesImportTask

type SQLAgenciesImportTask struct {
	SQLImportTask
}

func (SQLAgenciesImportTask) ConvertModels

func (m SQLAgenciesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}

func (SQLAgenciesImportTask) DoWork

func (m SQLAgenciesImportTask) DoWork(_ int)

func (SQLAgenciesImportTask) ImportModels

func (m SQLAgenciesImportTask) ImportModels(headers []string, as []interface{}) error

type SQLAgencyRepository

type SQLAgencyRepository struct {
	SQLGTFSModelRepository
}

func (SQLAgencyRepository) AddIndexesByAgencyKey

func (s SQLAgencyRepository) AddIndexesByAgencyKey(agencyKey string) error

func (SQLAgencyRepository) CreateImportTask

func (r SQLAgencyRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, lines []byte, done chan error) tasks.Task

func (SQLAgencyRepository) CreateTableByAgencyKey

func (s SQLAgencyRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error

func (SQLAgencyRepository) RemoveAllByAgencyKey

func (s SQLAgencyRepository) RemoveAllByAgencyKey(agencyKey string) error

type SQLCalendarDateRepository

type SQLCalendarDateRepository struct {
	SQLGTFSModelRepository
}

func (SQLCalendarDateRepository) AddIndexesByAgencyKey

func (s SQLCalendarDateRepository) AddIndexesByAgencyKey(agencyKey string) error

func (SQLCalendarDateRepository) CreateImportTask

func (r SQLCalendarDateRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, lines []byte, done chan error) tasks.Task

func (SQLCalendarDateRepository) CreateTableByAgencyKey

func (s SQLCalendarDateRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error

func (SQLCalendarDateRepository) RemoveAllByAgencyKey

func (s SQLCalendarDateRepository) RemoveAllByAgencyKey(agencyKey string) error

type SQLCalendarDatesImportTask

type SQLCalendarDatesImportTask struct {
	SQLImportTask
}

func (SQLCalendarDatesImportTask) ConvertModels

func (m SQLCalendarDatesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}

func (SQLCalendarDatesImportTask) DoWork

func (m SQLCalendarDatesImportTask) DoWork(_ int)

func (SQLCalendarDatesImportTask) ImportModels

func (m SQLCalendarDatesImportTask) ImportModels(headers []string, as []interface{}) error

type SQLCalendarRepository

type SQLCalendarRepository struct {
	SQLGTFSModelRepository
}

func (SQLCalendarRepository) AddIndexesByAgencyKey

func (s SQLCalendarRepository) AddIndexesByAgencyKey(agencyKey string) error

func (SQLCalendarRepository) CreateImportTask

func (r SQLCalendarRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, lines []byte, done chan error) tasks.Task

func (SQLCalendarRepository) CreateTableByAgencyKey

func (s SQLCalendarRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error

func (SQLCalendarRepository) RemoveAllByAgencyKey

func (s SQLCalendarRepository) RemoveAllByAgencyKey(agencyKey string) error

type SQLCalendarsImportTask

type SQLCalendarsImportTask struct {
	SQLImportTask
}

func (SQLCalendarsImportTask) ConvertModels

func (m SQLCalendarsImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}

func (SQLCalendarsImportTask) DoWork

func (m SQLCalendarsImportTask) DoWork(_ int)

func (SQLCalendarsImportTask) ImportModels

func (m SQLCalendarsImportTask) ImportModels(headers []string, as []interface{}) error

type SQLConnectionProvider

type SQLConnectionProvider interface {
	OpenSqlConnection() (*sql.DB, error)
}

type SQLGTFSModelRepository

type SQLGTFSModelRepository struct {
	// contains filtered or unexported fields
}

type SQLGTFSRepository

type SQLGTFSRepository struct {
	// contains filtered or unexported fields
}

func (SQLGTFSRepository) Agencies

func (SQLGTFSRepository) CalendarDates

func (SQLGTFSRepository) Calendars

func (SQLGTFSRepository) CreateSchema

func (r SQLGTFSRepository) CreateSchema(agencyKey string) error

func (SQLGTFSRepository) GtfsAgencies

func (SQLGTFSRepository) Routes

func (SQLGTFSRepository) StopTimes

func (SQLGTFSRepository) Stops

func (SQLGTFSRepository) Transfers

func (SQLGTFSRepository) Trips

type SQLGtfsAgenciesImportTask

type SQLGtfsAgenciesImportTask struct {
	SQLImportTask
}

func (SQLGtfsAgenciesImportTask) ConvertModels

func (m SQLGtfsAgenciesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}

func (SQLGtfsAgenciesImportTask) DoWork

func (m SQLGtfsAgenciesImportTask) DoWork(_ int)

func (SQLGtfsAgenciesImportTask) ImportModels

func (m SQLGtfsAgenciesImportTask) ImportModels(headers []string, as []interface{}) error

type SQLGtfsAgencyRepository

type SQLGtfsAgencyRepository struct {
	SQLGTFSModelRepository
}

func (SQLGtfsAgencyRepository) AddIndexesByAgencyKey

func (s SQLGtfsAgencyRepository) AddIndexesByAgencyKey(agencyKey string) error

func (SQLGtfsAgencyRepository) CreateImportTask

func (r SQLGtfsAgencyRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, lines []byte, done chan error) tasks.Task

func (SQLGtfsAgencyRepository) RemoveAllByAgencyKey

func (s SQLGtfsAgencyRepository) RemoveAllByAgencyKey(agencyKey string) error

type SQLImportTask

type SQLImportTask struct {
	tasks.ImportTask
	// contains filtered or unexported fields
}

func (*SQLImportTask) OpenSqlConnection

func (it *SQLImportTask) OpenSqlConnection() (*sql.DB, error)

type SQLRouteRepository

type SQLRouteRepository struct {
	SQLGTFSModelRepository
}

func (SQLRouteRepository) AddIndexesByAgencyKey

func (s SQLRouteRepository) AddIndexesByAgencyKey(agencyKey string) error

func (SQLRouteRepository) CreateImportTask

func (r SQLRouteRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, lines []byte, done chan error) tasks.Task

func (SQLRouteRepository) CreateTableByAgencyKey

func (s SQLRouteRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error

func (SQLRouteRepository) RemoveAllByAgencyKey

func (s SQLRouteRepository) RemoveAllByAgencyKey(agencyKey string) error

type SQLRoutesImportTask

type SQLRoutesImportTask struct {
	SQLImportTask
}

func (SQLRoutesImportTask) ConvertModels

func (m SQLRoutesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}

func (SQLRoutesImportTask) DoWork

func (m SQLRoutesImportTask) DoWork(_ int)

func (SQLRoutesImportTask) ImportModels

func (m SQLRoutesImportTask) ImportModels(headers []string, as []interface{}) error

type SQLStopRepository

type SQLStopRepository struct {
	SQLGTFSModelRepository
}

func (SQLStopRepository) AddIndexesByAgencyKey

func (s SQLStopRepository) AddIndexesByAgencyKey(agencyKey string) error

func (SQLStopRepository) CreateImportTask

func (r SQLStopRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, lines []byte, done chan error) tasks.Task

func (SQLStopRepository) CreateTableByAgencyKey

func (s SQLStopRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error

func (SQLStopRepository) RemoveAllByAgencyKey

func (s SQLStopRepository) RemoveAllByAgencyKey(agencyKey string) error

type SQLStopTimeRepository

type SQLStopTimeRepository struct {
	SQLGTFSModelRepository
}

func (SQLStopTimeRepository) AddIndexesByAgencyKey

func (s SQLStopTimeRepository) AddIndexesByAgencyKey(agencyKey string) error

func (SQLStopTimeRepository) CreateImportTask

func (r SQLStopTimeRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, lines []byte, done chan error) tasks.Task

func (SQLStopTimeRepository) CreateTableByAgencyKey

func (s SQLStopTimeRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error

func (SQLStopTimeRepository) RemoveAllByAgencyKey

func (s SQLStopTimeRepository) RemoveAllByAgencyKey(agencyKey string) error

type SQLStopTimesImportTask

type SQLStopTimesImportTask struct {
	SQLImportTask
}

func (SQLStopTimesImportTask) ConvertModels

func (m SQLStopTimesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}

func (SQLStopTimesImportTask) DoWork

func (m SQLStopTimesImportTask) DoWork(_ int)

func (SQLStopTimesImportTask) ImportModels

func (m SQLStopTimesImportTask) ImportModels(headers []string, sts []interface{}) error

type SQLStopsImportTask

type SQLStopsImportTask struct {
	SQLImportTask
}

func (SQLStopsImportTask) ConvertModels

func (m SQLStopsImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}

func (SQLStopsImportTask) DoWork

func (m SQLStopsImportTask) DoWork(_ int)

func (SQLStopsImportTask) ImportModels

func (m SQLStopsImportTask) ImportModels(headers []string, ss []interface{}) error

type SQLTransferRepository

type SQLTransferRepository struct {
	SQLGTFSModelRepository
}

func (SQLTransferRepository) AddIndexesByAgencyKey

func (s SQLTransferRepository) AddIndexesByAgencyKey(agencyKey string) error

func (SQLTransferRepository) CreateImportTask

func (r SQLTransferRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, lines []byte, done chan error) tasks.Task

func (SQLTransferRepository) CreateTableByAgencyKey

func (s SQLTransferRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error

func (SQLTransferRepository) RemoveAllByAgencyKey

func (s SQLTransferRepository) RemoveAllByAgencyKey(agencyKey string) error

type SQLTransfersImportTask

type SQLTransfersImportTask struct {
	SQLImportTask
}

func (SQLTransfersImportTask) ConvertModels

func (m SQLTransfersImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}

func (SQLTransfersImportTask) DoWork

func (m SQLTransfersImportTask) DoWork(_ int)

func (SQLTransfersImportTask) ImportModels

func (m SQLTransfersImportTask) ImportModels(headers []string, as []interface{}) error

type SQLTripRepository

type SQLTripRepository struct {
	SQLGTFSModelRepository
}

func (SQLTripRepository) AddIndexesByAgencyKey

func (s SQLTripRepository) AddIndexesByAgencyKey(agencyKey string) error

func (SQLTripRepository) CreateImportTask

func (r SQLTripRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, lines []byte, done chan error) tasks.Task

func (SQLTripRepository) CreateTableByAgencyKey

func (s SQLTripRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error

func (SQLTripRepository) RemoveAllByAgencyKey

func (s SQLTripRepository) RemoveAllByAgencyKey(agencyKey string) error

type SQLTripsImportTask

type SQLTripsImportTask struct {
	SQLImportTask
}

func (SQLTripsImportTask) ConvertModels

func (m SQLTripsImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}

func (SQLTripsImportTask) DoWork

func (m SQLTripsImportTask) DoWork(_ int)

func (SQLTripsImportTask) ImportModels

func (m SQLTripsImportTask) ImportModels(headers []string, as []interface{}) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL