Source implements qlbridge DataSource to a sqlite file based source. Features - Support full predicate push down to SqlLite. - Support Thread-Safe wrapper around sqlite file.
| 38 | // - Support full predicate push down to SqlLite. |
| 39 | // - Support Thread-Safe wrapper around sqlite file. |
| 40 | type Source struct { |
| 41 | exit <-chan bool |
| 42 | schema *schema.Schema |
| 43 | file string // Local file path to sqlite db |
| 44 | db *sql.DB |
| 45 | mu sync.Mutex |
| 46 | source *Source |
| 47 | qryconns map[string]*qryconn |
| 48 | tables map[string]*schema.Table |
| 49 | tblmu sync.Mutex |
| 50 | tableList []string |
| 51 | } |
| 52 | |
| 53 | func newSourceEmtpy() schema.Source { |
| 54 | return &Source{ |
nothing calls this directly
no outgoing calls
no test coverage detected