mirror of
https://github.com/aljazceru/turso.git
synced 2026-02-07 01:04:26 +01:00
core/mvcc: rebase fix
This commit is contained in:
@@ -1179,7 +1179,7 @@ impl Connection {
|
||||
&self.syms.read(),
|
||||
None,
|
||||
existing_views,
|
||||
self._db.mv_store.as_ref(),
|
||||
self.db.mv_store.as_ref(),
|
||||
)?;
|
||||
|
||||
tracing::debug!(
|
||||
@@ -1797,7 +1797,7 @@ impl Connection {
|
||||
&syms,
|
||||
None,
|
||||
existing_views,
|
||||
self._db.mv_store.as_ref(),
|
||||
self.db.mv_store.as_ref(),
|
||||
) {
|
||||
// this means that a vtab exists and we no longer have the module loaded. we print
|
||||
// a warning to the user to load the module
|
||||
|
||||
@@ -893,7 +893,7 @@ impl<Clock: LogicalClock> StateTransition for CommitStateMachine<Clock> {
|
||||
};
|
||||
if schema_did_change {
|
||||
let schema = connection.schema.borrow().clone();
|
||||
connection._db.update_schema_if_newer(schema)?;
|
||||
connection.db.update_schema_if_newer(schema)?;
|
||||
}
|
||||
if mvcc_store.storage.is_logical_log() {
|
||||
let tx = mvcc_store.txs.get(&self.tx_id).unwrap();
|
||||
|
||||
Reference in New Issue
Block a user