lsm/mdbtools
1
0
Fork 0
mirror of https://github.com/mdbtools/mdbtools.git synced 2025-04-05 20:31:00 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

change to processing of data pages

Browse Source
This commit is contained in:
brianb 2000-03-17 00:24:50 +00:00
parent a619228310
commit 375a4ea169
2 changed files with 21 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/include/mdbtools.h
View File

@ -95,7 +95,8 @@ typedef struct {
int num_pgs;
int first_data_pg;
GPtrArray *columns;
int cur_pg;
int cur_pg_num;
int cur_phys_pg;
int cur_row;
} MdbTableDef;

33
src/libmdb/data.c
View File

@ -171,9 +171,21 @@ int bitmask_sz;
row_end = row_start-1;
}
int mdb_read_next_dpg(MdbTableDef *table)
{
MdbCatalogEntry *entry = table->entry;
MdbHandle *mdb = entry->mdb;
do {
if (!mdb_read_pg(mdb, table->cur_phys_pg++))
return 0;
} while (mdb->pg_buf[0]!=0x01 || mdb_get_int32(mdb, 4)!=entry->table_pg);
return table->cur_phys_pg;
}
int mdb_rewind_table(MdbTableDef *table)
{
table->cur_pg=0;
table->cur_pg_num=0;
table->cur_phys_pg=0;
table->cur_row=0;
}
int mdb_fetch_row(MdbTableDef *table)
@ -181,28 +193,21 @@ int mdb_fetch_row(MdbTableDef *table)
MdbHandle *mdb = table->entry->mdb;
int rows;
if (table->cur_pg > table->num_pgs) {
return 0;
}
if (!table->cur_pg) {
table->cur_pg=1;
if (!table->cur_pg_num) {
table->cur_pg_num=1;
table->cur_row=0;
mdb_read_pg(mdb,table->first_data_pg + table->cur_pg);
mdb_read_next_dpg(table);
}
rows = mdb_get_int16(mdb,8);
mdb_read_row(table,
table->first_data_pg + table->cur_pg,
table->cur_pg_num,
table->cur_row);
table->cur_row++;
if (table->cur_row >= rows) {
if (table->cur_row > rows) {
table->cur_row=0;
table->cur_pg++;
if (table->cur_pg <= table->num_pgs) {
mdb_read_pg(mdb,table->first_data_pg + table->cur_pg);
}
if (!mdb_read_next_dpg(table)) return 0;
}
return 1;
}