diff --git a/source/libs/tdb/src/db/tdbPgCache.c b/source/libs/tdb/src/db/tdbPgCache.c
index c7ec7b0cc5..68e8e26d8a 100644
--- a/source/libs/tdb/src/db/tdbPgCache.c
+++ b/source/libs/tdb/src/db/tdbPgCache.c
@@ -29,7 +29,8 @@ struct SPCache {
   SPgHdr *        pFree;
 };
 
-#define PCACHE_PAGE_HASH(pgid) 0  // TODO
+#define PCACHE_PAGE_HASH(pgid)  0     // TODO
+#define PAGE_IS_UNPINNED(pPage) true  // TODO
 
 static void    tdbPCacheInitLock(SPCache *pCache);
 static void    tdbPCacheClearLock(SPCache *pCache);
@@ -37,6 +38,7 @@ static void    tdbPCacheLock(SPCache *pCache);
 static void    tdbPCacheUnlock(SPCache *pCache);
 static bool    tdbPCacheLocked(SPCache *pCache);
 static SPgHdr *tdbPCacheFetchImpl(SPCache *pCache, const SPgid *pPgid, bool alcNewPage);
+static void    tdbPCachePinPage(SPgHdr *pPage);
 
 int tdbOpenPCache(int pageSize, int cacheSize, int extraSize, SPCache **ppCache) {
   SPCache *pCache;
@@ -113,14 +115,16 @@ static SPgHdr *tdbPCacheFetchImpl(SPCache *pCache, const SPgid *pPgid, bool alcN
     pPage = pPage->pHashNext;
   }
 
-  if (pPage) {
-    // TODO: pin the page and return the page
-    return pPage;
-  } else if (!alcNewPage) {
+  if (pPage || !alcNewPage) {
+    if (pPage) tdbPCachePinPage(pPage);
     return pPage;
   }
 
-  // Try other methods
-
   return pPage;
+}
+
+static void tdbPCachePinPage(SPgHdr *pPage) {
+  if (PAGE_IS_UNPINNED(pPage)) {
+    /* TODO */
+  }
 }
\ No newline at end of file
diff --git a/source/libs/tdb/src/inc/tdbPgCache.h b/source/libs/tdb/src/inc/tdbPgCache.h
index d362f1f0ee..784cb32051 100644
--- a/source/libs/tdb/src/inc/tdbPgCache.h
+++ b/source/libs/tdb/src/inc/tdbPgCache.h
@@ -27,6 +27,7 @@ struct SPgHdr {
   void *  pData;
   void *  pExtra;
   SPgid   pgid;
+  uint8_t isLocalPage;
   SPgHdr *pFreeNext;
   SPgHdr *pHashNext;
 };
diff --git a/source/libs/tdb/src/sqlite/pager.c b/source/libs/tdb/src/sqlite/pager.c
index 23f4db4f06..573e9ef316 100644
--- a/source/libs/tdb/src/sqlite/pager.c
+++ b/source/libs/tdb/src/sqlite/pager.c
@@ -82,7 +82,6 @@
 // #define SPILLFLAG_NOSYNC      0x04 /* Spill is ok, but do not sync */
 
 struct Pager {
-  sqlite3_vfs *pVfs;          /* OS functions to use for IO */
   u8           exclusiveMode; /* Boolean. True if locking_mode==EXCLUSIVE */
   u8           journalMode;   /* One of the PAGER_JOURNALMODE_* values */
   u8           useJournal;    /* Use a rollback journal on this file */
@@ -4099,86 +4098,85 @@ int sqlite3PagerOpen(Pager **ppPager, const char *zFilename, int nExtra, int fla
   **    + The value returned by sqlite3OsSectorSize()
   **    + The largest page size that can be written atomically.
   */
-  if (rc == SQLITE_OK) {
-    int iDc = sqlite3OsDeviceCharacteristics(pPager->fd);
-    if (!readOnly) {
-      setSectorSize(pPager);
-      assert(SQLITE_DEFAULT_PAGE_SIZE <= SQLITE_MAX_DEFAULT_PAGE_SIZE);
-      if (szPageDflt < pPager->sectorSize) {
-        if (pPager->sectorSize > SQLITE_MAX_DEFAULT_PAGE_SIZE) {
-          szPageDflt = SQLITE_MAX_DEFAULT_PAGE_SIZE;
-        } else {
-          szPageDflt = (u32)pPager->sectorSize;
-        }
-      }
-    }
-    pPager->noLock = sqlite3_uri_boolean(pPager->zFilename, "nolock", 0);
-    if ((iDc & SQLITE_IOCAP_IMMUTABLE) != 0 || sqlite3_uri_boolean(pPager->zFilename, "immutable", 0)) {
-      vfsFlags |= SQLITE_OPEN_READONLY;
-      goto act_like_temp_file;
-    }
-  }
-  /* The following call to PagerSetPagesize() serves to set the value of
-  ** Pager.pageSize and to allocate the Pager.pTmpSpace buffer.
-  */
-  if (rc == SQLITE_OK) {
-    assert(pPager->memDb == 0);
-    rc = sqlite3PagerSetPagesize(pPager, &szPageDflt, -1);
-    testcase(rc != SQLITE_OK);
-  }
+  // if (rc == SQLITE_OK) {
+  //   int iDc = sqlite3OsDeviceCharacteristics(pPager->fd);
+  //   if (!readOnly) {
+  //     setSectorSize(pPager);
+  //     if (szPageDflt < pPager->sectorSize) {
+  //       if (pPager->sectorSize > SQLITE_MAX_DEFAULT_PAGE_SIZE) {
+  //         szPageDflt = SQLITE_MAX_DEFAULT_PAGE_SIZE;
+  //       } else {
+  //         szPageDflt = (u32)pPager->sectorSize;
+  //       }
+  //     }
+  //   }
+  //   pPager->noLock = sqlite3_uri_boolean(pPager->zFilename, "nolock", 0);
+  //   if ((iDc & SQLITE_IOCAP_IMMUTABLE) != 0 || sqlite3_uri_boolean(pPager->zFilename, "immutable", 0)) {
+  //     vfsFlags |= SQLITE_OPEN_READONLY;
+  //     goto act_like_temp_file;
+  //   }
+  // }
+  // /* The following call to PagerSetPagesize() serves to set the value of
+  // ** Pager.pageSize and to allocate the Pager.pTmpSpace buffer.
+  // */
+  // if (rc == SQLITE_OK) {
+  //   assert(pPager->memDb == 0);
+  //   rc = sqlite3PagerSetPagesize(pPager, &szPageDflt, -1);
+  //   testcase(rc != SQLITE_OK);
+  // }
 
-  /* Initialize the PCache object. */
-  if (rc == SQLITE_OK) {
-    nExtra = ROUND8(nExtra);
-    assert(nExtra >= 8 && nExtra < 1000);
-    rc = sqlite3PcacheOpen(szPageDflt, nExtra, !memDb, !memDb ? pagerStress : 0, (void *)pPager, pPager->pPCache);
-  }
+  // /* Initialize the PCache object. */
+  // if (rc == SQLITE_OK) {
+  //   nExtra = ROUND8(nExtra);
+  //   assert(nExtra >= 8 && nExtra < 1000);
+  //   rc = sqlite3PcacheOpen(szPageDflt, nExtra, !memDb, !memDb ? pagerStress : 0, (void *)pPager, pPager->pPCache);
+  // }
 
-  /* If an error occurred above, free the  Pager structure and close the file.
-   */
-  if (rc != SQLITE_OK) {
-    sqlite3OsClose(pPager->fd);
-    sqlite3PageFree(pPager->pTmpSpace);
-    sqlite3_free(pPager);
-    return rc;
-  }
+  // /* If an error occurred above, free the  Pager structure and close the file.
+  //  */
+  // if (rc != SQLITE_OK) {
+  //   sqlite3OsClose(pPager->fd);
+  //   sqlite3PageFree(pPager->pTmpSpace);
+  //   sqlite3_free(pPager);
+  //   return rc;
+  // }
 
-  PAGERTRACE(("OPEN %d %s\n", FILEHANDLEID(pPager->fd), pPager->zFilename));
-  IOTRACE(("OPEN %p %s\n", pPager, pPager->zFilename))
+  // PAGERTRACE(("OPEN %d %s\n", FILEHANDLEID(pPager->fd), pPager->zFilename));
+  // IOTRACE(("OPEN %p %s\n", pPager, pPager->zFilename))
 
-  pPager->useJournal = (u8)useJournal;
-  pPager->mxPgno = SQLITE_MAX_PAGE_COUNT;
-  pPager->tempFile = (u8)tempFile;
-  assert(tempFile == PAGER_LOCKINGMODE_NORMAL || tempFile == PAGER_LOCKINGMODE_EXCLUSIVE);
-  assert(PAGER_LOCKINGMODE_EXCLUSIVE == 1);
-  pPager->exclusiveMode = (u8)tempFile;
-  pPager->changeCountDone = pPager->tempFile;
-  pPager->memDb = (u8)memDb;
-  pPager->readOnly = (u8)readOnly;
-  assert(useJournal || pPager->tempFile);
-  pPager->noSync = pPager->tempFile;
-  if (pPager->noSync) {
-    assert(pPager->fullSync == 0);
-    assert(pPager->extraSync == 0);
-    assert(pPager->syncFlags == 0);
-    assert(pPager->walSyncFlags == 0);
-  } else {
-    pPager->fullSync = 1;
-    pPager->extraSync = 0;
-    pPager->syncFlags = SQLITE_SYNC_NORMAL;
-    pPager->walSyncFlags = SQLITE_SYNC_NORMAL | (SQLITE_SYNC_NORMAL << 2);
-  }
-  pPager->nExtra = (u16)nExtra;
-  pPager->journalSizeLimit = SQLITE_DEFAULT_JOURNAL_SIZE_LIMIT;
-  assert(isOpen(pPager->fd) || tempFile);
-  setSectorSize(pPager);
-  if (!useJournal) {
-    pPager->journalMode = PAGER_JOURNALMODE_OFF;
-  } else if (memDb || memJM) {
-    pPager->journalMode = PAGER_JOURNALMODE_MEMORY;
-  }
-  pPager->xReiniter = xReinit;
-  setGetterMethod(pPager);
+  // pPager->useJournal = (u8)useJournal;
+  // pPager->mxPgno = SQLITE_MAX_PAGE_COUNT;
+  // pPager->tempFile = (u8)tempFile;
+  // assert(tempFile == PAGER_LOCKINGMODE_NORMAL || tempFile == PAGER_LOCKINGMODE_EXCLUSIVE);
+  // assert(PAGER_LOCKINGMODE_EXCLUSIVE == 1);
+  // pPager->exclusiveMode = (u8)tempFile;
+  // pPager->changeCountDone = pPager->tempFile;
+  // pPager->memDb = (u8)memDb;
+  // pPager->readOnly = (u8)readOnly;
+  // assert(useJournal || pPager->tempFile);
+  // pPager->noSync = pPager->tempFile;
+  // if (pPager->noSync) {
+  //   assert(pPager->fullSync == 0);
+  //   assert(pPager->extraSync == 0);
+  //   assert(pPager->syncFlags == 0);
+  //   assert(pPager->walSyncFlags == 0);
+  // } else {
+  //   pPager->fullSync = 1;
+  //   pPager->extraSync = 0;
+  //   pPager->syncFlags = SQLITE_SYNC_NORMAL;
+  //   pPager->walSyncFlags = SQLITE_SYNC_NORMAL | (SQLITE_SYNC_NORMAL << 2);
+  // }
+  // pPager->nExtra = (u16)nExtra;
+  // pPager->journalSizeLimit = SQLITE_DEFAULT_JOURNAL_SIZE_LIMIT;
+  // assert(isOpen(pPager->fd) || tempFile);
+  // setSectorSize(pPager);
+  // if (!useJournal) {
+  //   pPager->journalMode = PAGER_JOURNALMODE_OFF;
+  // } else if (memDb || memJM) {
+  //   pPager->journalMode = PAGER_JOURNALMODE_MEMORY;
+  // }
+  // pPager->xReiniter = xReinit;
+  // setGetterMethod(pPager);
 
   *ppPager = pPager;
   return SQLITE_OK;
diff --git a/source/libs/tdb/src/sqliteinc/sqliteInt.h b/source/libs/tdb/src/sqliteinc/sqliteInt.h
index 6f29dd5e19..b6c44aa975 100644
--- a/source/libs/tdb/src/sqliteinc/sqliteInt.h
+++ b/source/libs/tdb/src/sqliteinc/sqliteInt.h
@@ -14,11 +14,14 @@
 */
 
 #include <assert.h>
+#include <fcntl.h>
 #include <pthread.h>
 #include <stddef.h>
 #include <stdint.h>
 #include <stdlib.h>
 #include <string.h>
+#include <sys/stat.h>
+#include <sys/types.h>
 
 #ifndef SQLITEINT_H
 #define SQLITEINT_H