sql

package
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 (r SQLGTFSRepository) Agencies() database.GTFSCreatedModelRepository

func (SQLGTFSRepository) CalendarDates 

func (r SQLGTFSRepository) CalendarDates() database.GTFSCreatedModelRepository

func (SQLGTFSRepository) Calendars 

func (r SQLGTFSRepository) Calendars() database.GTFSCreatedModelRepository

func (SQLGTFSRepository) CreateSchema 

func (r SQLGTFSRepository) CreateSchema(agencyKey string) error

func (SQLGTFSRepository) GtfsAgencies 

func (r SQLGTFSRepository) GtfsAgencies() database.GTFSModelRepository

func (SQLGTFSRepository) Routes 

func (r SQLGTFSRepository) Routes() database.GTFSCreatedModelRepository

func (SQLGTFSRepository) StopTimes 

func (r SQLGTFSRepository) StopTimes() database.GTFSCreatedModelRepository

func (SQLGTFSRepository) Stops 

func (r SQLGTFSRepository) Stops() database.GTFSCreatedModelRepository

func (SQLGTFSRepository) Transfers 

func (r SQLGTFSRepository) Transfers() database.GTFSCreatedModelRepository

func (SQLGTFSRepository) Trips 

func (r SQLGTFSRepository) Trips() database.GTFSCreatedModelRepository

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.