30985772317

Committed 05 Aug 2026 07:27AM UTC coverage: 89.114% (+0.001%) from 89.113%

Build # 30985772317

Build Type

Pull #290

github

Committed by

linuxdynasty

Commit Message

fix(cypher): include properties in relationship merge identity

Pull Request Pull Request #290: fix(cypher): include properties in relationship merge identity

Coverage Stats

342 of 396 new or added lines in 8 files covered. (86.36%)

30 existing lines in 11 files now uncovered.

148320 of 166438 relevant lines covered (89.11%)

1.04 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

69.57

/pkg/bolt/committed_write_cache.go

package bolt

type committedWriteCacheInvalidator interface {
        InvalidateCommittedWriteCaches()
}

type pendingTransactionWriteReporter interface {
        HasPendingTransactionWrites() bool
}

func (s *Session) invalidateCommittedWriteCaches(databaseName string) {
        if s == nil {
                return
        }
        if invalidator, ok := s.baseExec.(committedWriteCacheInvalidator); ok {
                invalidator.InvalidateCommittedWriteCaches()
        } else if provider, ok := s.baseExec.(baseCypherExecutorProvider); ok {
                if executor := provider.BaseCypherExecutor(); executor != nil {
                        executor.InvalidateCommittedWriteCaches()
                }
        }
        if s.server == nil {
                return
        }

        s.server.executorsMu.RLock()
        databaseExecutor := s.server.executors[databaseName]
        s.server.executorsMu.RUnlock()
        if invalidator, ok := databaseExecutor.(committedWriteCacheInvalidator); ok {
                invalidator.InvalidateCommittedWriteCaches()
        }
}

func (a *boltQueryExecutorAdapter) InvalidateCommittedWriteCaches() {
        if a != nil && a.executor != nil {
                a.executor.InvalidateCommittedWriteCaches()
        }
}

1	package bolt
2
3	type committedWriteCacheInvalidator interface {
4	InvalidateCommittedWriteCaches()
5	}
6
7	type pendingTransactionWriteReporter interface {
8	HasPendingTransactionWrites() bool
9	}
10
11	func (s *Session) invalidateCommittedWriteCaches(databaseName string) {	1✔
12	if s == nil {	1✔
NEW 13	return	×
NEW 14	}	×
15	if invalidator, ok := s.baseExec.(committedWriteCacheInvalidator); ok {	2✔
16	invalidator.InvalidateCommittedWriteCaches()	1✔
17	} else if provider, ok := s.baseExec.(baseCypherExecutorProvider); ok {	2✔
NEW 18	if executor := provider.BaseCypherExecutor(); executor != nil {	×
NEW 19	executor.InvalidateCommittedWriteCaches()	×
NEW 20	}	×
21	}
22	if s.server == nil {	1✔
NEW 23	return	×
NEW 24	}	×
25
26	s.server.executorsMu.RLock()	1✔
27	databaseExecutor := s.server.executors[databaseName]	1✔
28	s.server.executorsMu.RUnlock()	1✔
29	if invalidator, ok := databaseExecutor.(committedWriteCacheInvalidator); ok {	2✔
30	invalidator.InvalidateCommittedWriteCaches()	1✔
31	}	1✔
32	}
33
34	func (a *boltQueryExecutorAdapter) InvalidateCommittedWriteCaches() {	1✔
35	if a != nil && a.executor != nil {	2✔
36	a.executor.InvalidateCommittedWriteCaches()	1✔
37	}	1✔
38	}

orneryd / NornicDB / 30985772317

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous