Method Update

internal/db/sqlite/folderdb_update.go:34–189

(device protocol.DeviceID, fs []protocol.FileInfo, options db.UpdateOptions)

)

func (s *folderDB) Update(device protocol.DeviceID, fs []protocol.FileInfo, options db.UpdateOptions) error {
	s.updateLock.Lock()
	defer s.updateLock.Unlock()

	deviceIdx, err := s.deviceIdxLocked(device)
	if err != nil {
		return wrap(err)
	}

	tx, err := s.sql.BeginTxx(context.Background(), nil)
	if err != nil {
		return wrap(err)
	}
	defer tx.Rollback() //nolint:errcheck
	txp := &txPreparedStmts{Tx: tx}

	//nolint:sqlclosecheck
	insertNameStmt, err := txp.Preparex(`
		INSERT INTO file_names(name)
		VALUES (?)
		ON CONFLICT(name) DO UPDATE
			SET name = excluded.name
		RETURNING idx
	`)
	if err != nil {
		return wrap(err, "prepare insert name")
	}

	//nolint:sqlclosecheck
	insertVersionStmt, err := txp.Preparex(`
		INSERT INTO file_versions (version)
		VALUES (?)
		ON CONFLICT(version) DO UPDATE
			SET version = excluded.version
		RETURNING idx
	`)
	if err != nil {
		return wrap(err, "prepare insert version")
	}

	//nolint:sqlclosecheck
	insertFileStmt, err := txp.Preparex(`
		INSERT OR REPLACE INTO files (device_idx, remote_sequence, type, modified, size, deleted, local_flags, blocklist_hash, name_idx, version_idx)
		VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
		RETURNING sequence
	`)
	if err != nil {
		return wrap(err, "prepare insert file")
	}

	//nolint:sqlclosecheck
	insertFileInfoStmt, err := txp.Preparex(`
		INSERT INTO fileinfos (sequence, fiprotobuf)
		VALUES (?, ?)
	`)
	if err != nil {
		return wrap(err, "prepare insert fileinfo")
	}