Function newSQLWriter

go/sqlfs/sql_writer.go:49–57

(db *database.DB, table string, bufSize int)

}

func newSQLWriter(db *database.DB, table string, bufSize int) (io.WriteCloser, error) {
	if e := dropTableIfExists(db.DB, table); e != nil {
		return nil, fmt.Errorf("cannot drop table %s: %v", table, e)
	}
	if e := createTable(db, table); e != nil {
		return nil, fmt.Errorf("cannot create table %s: %v", table, e)
	}
	return newFlushWriteCloser(flushToSQLTable(db.DB, table), noopWrapUp, bufSize), nil
}