Function Load

internal/dag/sqlite.go:35–69

(log log.Log, dbPath string)

}

func Load(log log.Log, dbPath string) (*DB, error) {
	// Make the path directory
	if err := os.MkdirAll(filepath.Dir(dbPath), 0755); err != nil {
		return nil, err
	}
	// Open the SQLite database
	db, err := sql.Open("sqlite3", dbPath)
	if err != nil {
		return nil, fmt.Errorf("dag/sqlite: unable to open %q. %w", dbPath, err)
	}

	// Create the files and links tables.
	if _, err := db.Exec(`
		CREATE TABLE IF NOT EXISTS files (
			path TEXT PRIMARY KEY,
			data BLOB,
			mode INTEGER
		)
	`); err != nil {
		return nil, fmt.Errorf("dag/sqlite: unable to create files table. %w", err)
	}
	if _, err := db.Exec(`
		CREATE TABLE IF NOT EXISTS links (
			from_path TEXT,
			to_path TEXT,
			FOREIGN KEY(from_path) REFERENCES files(path),
			FOREIGN KEY(to_path) REFERENCES files(path),
			PRIMARY KEY(from_path, to_path)
		)
	`); err != nil {
		return nil, fmt.Errorf("dag/sqlite: unable to create links table. %w", err)
	}

	return &DB{db, log, dbPath}, nil
}

type DB struct {
	db     *sql.DB