Function TestDB_Close_CompleteShutdownFlow

db_test.go:871–917

TestDB_Close_CompleteShutdownFlow tests the complete shutdown flow

(t *testing.T)

// TestDB_Close_CompleteShutdownFlow tests the complete shutdown flow
func TestDB_Close_CompleteShutdownFlow(t *testing.T) {
	opts := DefaultOptions
	opts.Dir = filepath.Join(t.TempDir(), "test-close-complete")
	defer func() { _ = os.RemoveAll(opts.Dir) }()

	db, err := Open(opts)
	require.NoError(t, err)
	require.NotNil(t, db)

	// Create a bucket and add some data
	bucket := "test_bucket"
	err = db.Update(func(tx *Tx) error {
		return tx.NewBucket(DataStructureBTree, bucket)
	})
	require.NoError(t, err)

	// Add some test data
	for i := 0; i < 10; i++ {
		key := testutils.GetTestBytes(i)
		val := testutils.GetRandomBytes(100)
		err = db.Update(func(tx *Tx) error {
			return tx.Put(bucket, key, val, Persistent)
		})
		require.NoError(t, err)
	}

	// Verify database is operational before close
	require.False(t, db.IsClose())
	require.False(t, db.statusMgr.isClosingOrClosed())

	// Close the database
	err = db.Close()
	require.NoError(t, err)

	// Verify database is closed
	require.True(t, db.IsClose())
	require.True(t, db.statusMgr.isClosed())

	// Verify resources are released
	require.Nil(t, db.ActiveFile)
	require.Nil(t, db.Index)
	require.Nil(t, db.fm)
	require.Nil(t, db.commitBuffer)

	// Verify file lock is released
	require.False(t, db.flock.Locked())
}

// TestDB_Close_WithActiveTxs tests closing database with active transactions
func TestDB_Close_WithActiveTxs(t *testing.T) {