Function importFromSQLite

server/import.go:48–126

(ctx context.Context, ch *CHStore, sqlitePath string)

}

func importFromSQLite(ctx context.Context, ch *CHStore, sqlitePath string) error {
	sdb, err := sql.Open("sqlite", sqlitePath)
	if err != nil {
		return fmt.Errorf("open sqlite: %w", err)
	}
	defer sdb.Close()

	// Import from both tables if they exist
	for _, src := range []struct {
		table string
		dest  string
	}{
		{"known_dlls", "known_dlls"},
		{"known_jars", "known_jars"},
	} {
		// Check if source table exists
		var name string
		err := sdb.QueryRow(`SELECT name FROM sqlite_master WHERE type='table' AND name=?`, src.table).Scan(&name)
		if err != nil {
			continue // table doesn't exist, skip
		}

		rows, err := sdb.Query(fmt.Sprintf(`SELECT dll_name, source, package_name, version, hash FROM %s`, src.table))
		if err != nil {
			return fmt.Errorf("query sqlite %s: %w", src.table, err)
		}

		batch := make([][]interface{}, 0, importBatchSize)
		total := 0

		for rows.Next() {
			var dllName, source string
			var packageName, version, hash sql.NullString

			if err := rows.Scan(&dllName, &source, &packageName, &version, &hash); err != nil {
				rows.Close()
				return fmt.Errorf("scan row: %w", err)
			}

			pkg := ""
			if packageName.Valid {
				pkg = packageName.String
			}
			ver := ""
			if version.Valid {
				ver = version.String
			}
			h := ""
			if hash.Valid {
				h = hash.String
			}

			batch = append(batch, []interface{}{dllName, source, pkg, ver, h})
			total++

			if len(batch) >= importBatchSize {
				if err := flushBatch(ctx, ch, src.dest, batch, total); err != nil {
					rows.Close()