1 /* 2 ** A utility for printing all or part of an SQLite database file. 3 */ 4 #include <stdio.h> 5 #include <ctype.h> 6 #define ISDIGIT(X) isdigit((unsigned char)(X)) 7 #define ISPRINT(X) isprint((unsigned char)(X)) 8 #include <sys/types.h> 9 #include <sys/stat.h> 10 #include <fcntl.h> 11 12 #if !defined(_MSC_VER) 13 #include <unistd.h> 14 #else 15 #include <io.h> 16 #endif 17 18 #include <stdlib.h> 19 #include <string.h> 20 #include <assert.h> 21 #include "sqlite3.h" 22 23 typedef unsigned char u8; /* unsigned 8-bit */ 24 typedef unsigned int u32; /* unsigned 32-bit */ 25 typedef sqlite3_int64 i64; /* signed 64-bit */ 26 typedef sqlite3_uint64 u64; /* unsigned 64-bit */ 27 28 29 static struct GlobalData { 30 u32 pagesize; /* Size of a database page */ 31 int dbfd; /* File descriptor for reading the DB */ 32 u32 mxPage; /* Last page number */ 33 int perLine; /* HEX elements to print per line */ 34 int bRaw; /* True to access db file via OS APIs */ 35 sqlite3_file *pFd; /* File descriptor for non-raw mode */ 36 sqlite3 *pDb; /* Database handle that owns pFd */ 37 } g = {1024, -1, 0, 16, 0, 0, 0}; 38 39 /* 40 ** Convert the var-int format into i64. Return the number of bytes 41 ** in the var-int. Write the var-int value into *pVal. 42 */ 43 static int decodeVarint(const unsigned char *z, i64 *pVal){ 44 i64 v = 0; 45 int i; 46 for(i=0; i<8; i++){ 47 v = (v<<7) + (z[i]&0x7f); 48 if( (z[i]&0x80)==0 ){ *pVal = v; return i+1; } 49 } 50 v = (v<<8) + (z[i]&0xff); 51 *pVal = v; 52 return 9; 53 } 54 55 /* 56 ** Extract a big-endian 32-bit integer 57 */ 58 static u32 decodeInt32(const u8 *z){ 59 return (z[0]<<24) + (z[1]<<16) + (z[2]<<8) + z[3]; 60 } 61 62 /* Report an out-of-memory error and die. 63 */ 64 static void out_of_memory(void){ 65 fprintf(stderr,"Out of memory...\n"); 66 exit(1); 67 } 68 69 /* 70 ** Open a database connection. 71 */ 72 static sqlite3 *openDatabase(const char *zPrg, const char *zName){ 73 sqlite3 *db = 0; 74 int flags = SQLITE_OPEN_READWRITE | SQLITE_OPEN_URI; 75 int rc = sqlite3_open_v2(zName, &db, flags, 0); 76 if( rc!=SQLITE_OK ){ 77 const char *zErr = sqlite3_errmsg(db); 78 fprintf(stderr, "%s: can't open %s (%s)\n", zPrg, zName, zErr); 79 sqlite3_close(db); 80 exit(1); 81 } 82 return db; 83 } 84 85 /************************************************************************** 86 ** Beginning of low-level file access functions. 87 ** 88 ** All low-level access to the database file read by this program is 89 ** performed using the following four functions: 90 ** 91 ** fileOpen() - open the db file 92 ** fileClose() - close the db file 93 ** fileRead() - read raw data from the db file 94 ** fileGetsize() - return the size of the db file in bytes 95 */ 96 97 /* 98 ** Open the database file. 99 */ 100 static void fileOpen(const char *zPrg, const char *zName){ 101 assert( g.dbfd<0 ); 102 if( g.bRaw==0 ){ 103 int rc; 104 void *pArg = (void *)(&g.pFd); 105 g.pDb = openDatabase(zPrg, zName); 106 rc = sqlite3_file_control(g.pDb, "main", SQLITE_FCNTL_FILE_POINTER, pArg); 107 if( rc!=SQLITE_OK ){ 108 fprintf(stderr, 109 "%s: failed to obtain fd for %s (SQLite too old?)\n", zPrg, zName 110 ); 111 exit(1); 112 } 113 }else{ 114 g.dbfd = open(zName, O_RDONLY); 115 if( g.dbfd<0 ){ 116 fprintf(stderr,"%s: can't open %s\n", zPrg, zName); 117 exit(1); 118 } 119 } 120 } 121 122 /* 123 ** Close the database file opened by fileOpen() 124 */ 125 static void fileClose(){ 126 if( g.bRaw==0 ){ 127 sqlite3_close(g.pDb); 128 g.pDb = 0; 129 g.pFd = 0; 130 }else{ 131 close(g.dbfd); 132 g.dbfd = -1; 133 } 134 } 135 136 /* 137 ** Read content from the file. 138 ** 139 ** Space to hold the content is obtained from sqlite3_malloc() and needs 140 ** to be freed by the caller. 141 */ 142 static unsigned char *fileRead(sqlite3_int64 ofst, int nByte){ 143 unsigned char *aData; 144 int got; 145 aData = sqlite3_malloc64(32+(i64)nByte); 146 if( aData==0 ) out_of_memory(); 147 memset(aData, 0, nByte+32); 148 if( g.bRaw==0 ){ 149 int rc = g.pFd->pMethods->xRead(g.pFd, (void*)aData, nByte, ofst); 150 if( rc!=SQLITE_OK && rc!=SQLITE_IOERR_SHORT_READ ){ 151 fprintf(stderr, "error in xRead() - %d\n", rc); 152 exit(1); 153 } 154 }else{ 155 lseek(g.dbfd, (long)ofst, SEEK_SET); 156 got = read(g.dbfd, aData, nByte); 157 if( got>0 && got<nByte ) memset(aData+got, 0, nByte-got); 158 } 159 return aData; 160 } 161 162 /* 163 ** Return the size of the file in byte. 164 */ 165 static i64 fileGetsize(void){ 166 i64 res = 0; 167 if( g.bRaw==0 ){ 168 int rc = g.pFd->pMethods->xFileSize(g.pFd, &res); 169 if( rc!=SQLITE_OK ){ 170 fprintf(stderr, "error in xFileSize() - %d\n", rc); 171 exit(1); 172 } 173 }else{ 174 struct stat sbuf; 175 fstat(g.dbfd, &sbuf); 176 res = (sqlite3_int64)(sbuf.st_size); 177 } 178 return res; 179 } 180 181 /* 182 ** End of low-level file access functions. 183 **************************************************************************/ 184 185 /* 186 ** Print a range of bytes as hex and as ascii. 187 */ 188 static unsigned char *print_byte_range( 189 sqlite3_int64 ofst, /* First byte in the range of bytes to print */ 190 int nByte, /* Number of bytes to print */ 191 int printOfst /* Add this amount to the index on the left column */ 192 ){ 193 unsigned char *aData; 194 int i, j; 195 const char *zOfstFmt; 196 197 if( ((printOfst+nByte)&~0xfff)==0 ){ 198 zOfstFmt = " %03x: "; 199 }else if( ((printOfst+nByte)&~0xffff)==0 ){ 200 zOfstFmt = " %04x: "; 201 }else if( ((printOfst+nByte)&~0xfffff)==0 ){ 202 zOfstFmt = " %05x: "; 203 }else if( ((printOfst+nByte)&~0xffffff)==0 ){ 204 zOfstFmt = " %06x: "; 205 }else{ 206 zOfstFmt = " %08x: "; 207 } 208 209 aData = fileRead(ofst, nByte); 210 for(i=0; i<nByte; i += g.perLine){ 211 int go = 0; 212 for(j=0; j<g.perLine; j++){ 213 if( i+j>nByte ){ break; } 214 if( aData[i+j] ){ go = 1; break; } 215 } 216 if( !go && i>0 && i+g.perLine<nByte ) continue; 217 fprintf(stdout, zOfstFmt, i+printOfst); 218 for(j=0; j<g.perLine; j++){ 219 if( i+j>nByte ){ 220 fprintf(stdout, " "); 221 }else{ 222 fprintf(stdout,"%02x ", aData[i+j]); 223 } 224 } 225 for(j=0; j<g.perLine; j++){ 226 if( i+j>nByte ){ 227 fprintf(stdout, " "); 228 }else{ 229 fprintf(stdout,"%c", ISPRINT(aData[i+j]) ? aData[i+j] : '.'); 230 } 231 } 232 fprintf(stdout,"\n"); 233 } 234 return aData; 235 } 236 237 /* 238 ** Print an entire page of content as hex 239 */ 240 static void print_page(u32 iPg){ 241 i64 iStart; 242 unsigned char *aData; 243 iStart = ((i64)(iPg-1))*g.pagesize; 244 fprintf(stdout, "Page %u: (offsets 0x%llx..0x%llx)\n", 245 iPg, iStart, iStart+g.pagesize-1); 246 aData = print_byte_range(iStart, g.pagesize, 0); 247 sqlite3_free(aData); 248 } 249 250 251 /* Print a line of decoded output showing a 4-byte unsigned integer. 252 */ 253 static void print_decode_line( 254 unsigned char *aData, /* Content being decoded */ 255 int ofst, int nByte, /* Start and size of decode */ 256 const char *zMsg /* Message to append */ 257 ){ 258 int i, j; 259 u32 val = aData[ofst]; 260 char zBuf[100]; 261 sprintf(zBuf, " %03x: %02x", ofst, aData[ofst]); 262 i = (int)strlen(zBuf); 263 for(j=1; j<4; j++){ 264 if( j>=nByte ){ 265 sprintf(&zBuf[i], " "); 266 }else{ 267 sprintf(&zBuf[i], " %02x", aData[ofst+j]); 268 val = val*256 + aData[ofst+j]; 269 } 270 i += (int)strlen(&zBuf[i]); 271 } 272 sprintf(&zBuf[i], " %10u", val); 273 printf("%s %s\n", zBuf, zMsg); 274 } 275 276 /* 277 ** Decode the database header. 278 */ 279 static void print_db_header(void){ 280 unsigned char *aData; 281 aData = print_byte_range(0, 100, 0); 282 printf("Decoded:\n"); 283 print_decode_line(aData, 16, 2, "Database page size"); 284 print_decode_line(aData, 18, 1, "File format write version"); 285 print_decode_line(aData, 19, 1, "File format read version"); 286 print_decode_line(aData, 20, 1, "Reserved space at end of page"); 287 print_decode_line(aData, 24, 4, "File change counter"); 288 print_decode_line(aData, 28, 4, "Size of database in pages"); 289 print_decode_line(aData, 32, 4, "Page number of first freelist page"); 290 print_decode_line(aData, 36, 4, "Number of freelist pages"); 291 print_decode_line(aData, 40, 4, "Schema cookie"); 292 print_decode_line(aData, 44, 4, "Schema format version"); 293 print_decode_line(aData, 48, 4, "Default page cache size"); 294 print_decode_line(aData, 52, 4, "Largest auto-vac root page"); 295 print_decode_line(aData, 56, 4, "Text encoding"); 296 print_decode_line(aData, 60, 4, "User version"); 297 print_decode_line(aData, 64, 4, "Incremental-vacuum mode"); 298 print_decode_line(aData, 68, 4, "Application ID"); 299 print_decode_line(aData, 72, 4, "meta[8]"); 300 print_decode_line(aData, 76, 4, "meta[9]"); 301 print_decode_line(aData, 80, 4, "meta[10]"); 302 print_decode_line(aData, 84, 4, "meta[11]"); 303 print_decode_line(aData, 88, 4, "meta[12]"); 304 print_decode_line(aData, 92, 4, "Change counter for version number"); 305 print_decode_line(aData, 96, 4, "SQLite version number"); 306 sqlite3_free(aData); 307 } 308 309 /* 310 ** Describe cell content. 311 */ 312 static i64 describeContent( 313 unsigned char *a, /* Cell content */ 314 i64 nLocal, /* Bytes in a[] */ 315 char *zDesc /* Write description here */ 316 ){ 317 i64 nDesc = 0; 318 int n, j; 319 i64 i, x, v; 320 const unsigned char *pData; 321 const unsigned char *pLimit; 322 char sep = ' '; 323 324 pLimit = &a[nLocal]; 325 n = decodeVarint(a, &x); 326 pData = &a[x]; 327 a += n; 328 i = x - n; 329 while( i>0 && pData<=pLimit ){ 330 n = decodeVarint(a, &x); 331 a += n; 332 i -= n; 333 nLocal -= n; 334 zDesc[0] = sep; 335 sep = ','; 336 nDesc++; 337 zDesc++; 338 if( x==0 ){ 339 sprintf(zDesc, "*"); /* NULL is a "*" */ 340 }else if( x>=1 && x<=6 ){ 341 v = (signed char)pData[0]; 342 pData++; 343 switch( x ){ 344 case 6: v = (v<<16) + (pData[0]<<8) + pData[1]; pData += 2; 345 case 5: v = (v<<16) + (pData[0]<<8) + pData[1]; pData += 2; 346 case 4: v = (v<<8) + pData[0]; pData++; 347 case 3: v = (v<<8) + pData[0]; pData++; 348 case 2: v = (v<<8) + pData[0]; pData++; 349 } 350 sprintf(zDesc, "%lld", v); 351 }else if( x==7 ){ 352 sprintf(zDesc, "real"); 353 pData += 8; 354 }else if( x==8 ){ 355 sprintf(zDesc, "0"); 356 }else if( x==9 ){ 357 sprintf(zDesc, "1"); 358 }else if( x>=12 ){ 359 i64 size = (x-12)/2; 360 if( (x&1)==0 ){ 361 sprintf(zDesc, "blob(%lld)", size); 362 }else{ 363 sprintf(zDesc, "txt(%lld)", size); 364 } 365 pData += size; 366 } 367 j = (int)strlen(zDesc); 368 zDesc += j; 369 nDesc += j; 370 } 371 return nDesc; 372 } 373 374 /* 375 ** Compute the local payload size given the total payload size and 376 ** the page size. 377 */ 378 static i64 localPayload(i64 nPayload, char cType){ 379 i64 maxLocal; 380 i64 minLocal; 381 i64 surplus; 382 i64 nLocal; 383 if( cType==13 ){ 384 /* Table leaf */ 385 maxLocal = g.pagesize-35; 386 minLocal = (g.pagesize-12)*32/255-23; 387 }else{ 388 maxLocal = (g.pagesize-12)*64/255-23; 389 minLocal = (g.pagesize-12)*32/255-23; 390 } 391 if( nPayload>maxLocal ){ 392 surplus = minLocal + (nPayload-minLocal)%(g.pagesize-4); 393 if( surplus<=maxLocal ){ 394 nLocal = surplus; 395 }else{ 396 nLocal = minLocal; 397 } 398 }else{ 399 nLocal = nPayload; 400 } 401 return nLocal; 402 } 403 404 405 /* 406 ** Create a description for a single cell. 407 ** 408 ** The return value is the local cell size. 409 */ 410 static i64 describeCell( 411 unsigned char cType, /* Page type */ 412 unsigned char *a, /* Cell content */ 413 int showCellContent, /* Show cell content if true */ 414 char **pzDesc /* Store description here */ 415 ){ 416 int i; 417 i64 nDesc = 0; 418 int n = 0; 419 u32 leftChild; 420 i64 nPayload; 421 i64 rowid; 422 i64 nLocal; 423 static char zDesc[1000]; 424 i = 0; 425 if( cType<=5 ){ 426 leftChild = ((a[0]*256 + a[1])*256 + a[2])*256 + a[3]; 427 a += 4; 428 n += 4; 429 sprintf(zDesc, "lx: %u ", leftChild); 430 nDesc = strlen(zDesc); 431 } 432 if( cType!=5 ){ 433 i = decodeVarint(a, &nPayload); 434 a += i; 435 n += i; 436 sprintf(&zDesc[nDesc], "n: %lld ", nPayload); 437 nDesc += strlen(&zDesc[nDesc]); 438 nLocal = localPayload(nPayload, cType); 439 }else{ 440 nPayload = nLocal = 0; 441 } 442 if( cType==5 || cType==13 ){ 443 i = decodeVarint(a, &rowid); 444 a += i; 445 n += i; 446 sprintf(&zDesc[nDesc], "r: %lld ", rowid); 447 nDesc += strlen(&zDesc[nDesc]); 448 } 449 if( nLocal<nPayload ){ 450 u32 ovfl; 451 unsigned char *b = &a[nLocal]; 452 ovfl = ((b[0]*256 + b[1])*256 + b[2])*256 + b[3]; 453 sprintf(&zDesc[nDesc], "ov: %u ", ovfl); 454 nDesc += strlen(&zDesc[nDesc]); 455 n += 4; 456 } 457 if( showCellContent && cType!=5 ){ 458 nDesc += describeContent(a, nLocal, &zDesc[nDesc-1]); 459 } 460 *pzDesc = zDesc; 461 return nLocal+n; 462 } 463 464 /* Print an offset followed by nByte bytes. Add extra white-space 465 ** at the end so that subsequent text is aligned. 466 */ 467 static void printBytes( 468 unsigned char *aData, /* Content being decoded */ 469 unsigned char *aStart, /* Start of content to be printed */ 470 int nByte /* Number of bytes to print */ 471 ){ 472 int j; 473 printf(" %03x: ", (int)(aStart-aData)); 474 for(j=0; j<9; j++){ 475 if( j>=nByte ){ 476 printf(" "); 477 }else{ 478 printf("%02x ", aStart[j]); 479 } 480 } 481 } 482 483 484 /* 485 ** Write a full decode on stdout for the cell at a[ofst]. 486 ** Assume the page contains a header of size szPgHdr bytes. 487 */ 488 static void decodeCell( 489 unsigned char *a, /* Page content (without the page-1 header) */ 490 unsigned pgno, /* Page number */ 491 int iCell, /* Cell index */ 492 int szPgHdr, /* Size of the page header. 0 or 100 */ 493 int ofst /* Cell begins at a[ofst] */ 494 ){ 495 int i, j = 0; 496 u32 leftChild; 497 i64 k; 498 i64 nPayload; 499 i64 rowid; 500 i64 nHdr; 501 i64 iType; 502 i64 nLocal; 503 unsigned char *x = a + ofst; 504 unsigned char *end; 505 unsigned char cType = a[0]; 506 int nCol = 0; 507 int szCol[2000]; 508 int ofstCol[2000]; 509 int typeCol[2000]; 510 511 printf("Cell[%d]:\n", iCell); 512 if( cType<=5 ){ 513 leftChild = ((x[0]*256 + x[1])*256 + x[2])*256 + x[3]; 514 printBytes(a, x, 4); 515 printf("left child page:: %u\n", leftChild); 516 x += 4; 517 } 518 if( cType!=5 ){ 519 i = decodeVarint(x, &nPayload); 520 printBytes(a, x, i); 521 nLocal = localPayload(nPayload, cType); 522 if( nLocal==nPayload ){ 523 printf("payload-size: %lld\n", nPayload); 524 }else{ 525 printf("payload-size: %lld (%lld local, %lld overflow)\n", 526 nPayload, nLocal, nPayload-nLocal); 527 } 528 x += i; 529 }else{ 530 nPayload = nLocal = 0; 531 } 532 end = x + nLocal; 533 if( cType==5 || cType==13 ){ 534 i = decodeVarint(x, &rowid); 535 printBytes(a, x, i); 536 printf("rowid: %lld\n", rowid); 537 x += i; 538 } 539 if( nLocal>0 ){ 540 i = decodeVarint(x, &nHdr); 541 printBytes(a, x, i); 542 printf("record-header-size: %d\n", (int)nHdr); 543 j = i; 544 nCol = 0; 545 k = nHdr; 546 while( x+j<=end && j<nHdr ){ 547 const char *zTypeName; 548 int sz = 0; 549 char zNm[30]; 550 i = decodeVarint(x+j, &iType); 551 printBytes(a, x+j, i); 552 printf("typecode[%d]: %d - ", nCol, (int)iType); 553 switch( iType ){ 554 case 0: zTypeName = "NULL"; sz = 0; break; 555 case 1: zTypeName = "int8"; sz = 1; break; 556 case 2: zTypeName = "int16"; sz = 2; break; 557 case 3: zTypeName = "int24"; sz = 3; break; 558 case 4: zTypeName = "int32"; sz = 4; break; 559 case 5: zTypeName = "int48"; sz = 6; break; 560 case 6: zTypeName = "int64"; sz = 8; break; 561 case 7: zTypeName = "double"; sz = 8; break; 562 case 8: zTypeName = "zero"; sz = 0; break; 563 case 9: zTypeName = "one"; sz = 0; break; 564 case 10: 565 case 11: zTypeName = "error"; sz = 0; break; 566 default: { 567 sz = (int)(iType-12)/2; 568 sprintf(zNm, (iType&1)==0 ? "blob(%d)" : "text(%d)", sz); 569 zTypeName = zNm; 570 break; 571 } 572 } 573 printf("%s\n", zTypeName); 574 szCol[nCol] = sz; 575 ofstCol[nCol] = (int)k; 576 typeCol[nCol] = (int)iType; 577 k += sz; 578 nCol++; 579 j += i; 580 } 581 for(i=0; i<nCol && ofstCol[i]+szCol[i]<=nLocal; i++){ 582 int s = ofstCol[i]; 583 i64 v; 584 const unsigned char *pData; 585 if( szCol[i]==0 ) continue; 586 printBytes(a, x+s, szCol[i]); 587 printf("data[%d]: ", i); 588 pData = x+s; 589 if( typeCol[i]<=7 ){ 590 v = (signed char)pData[0]; 591 for(k=1; k<szCol[i]; k++){ 592 v = (v<<8) + pData[k]; 593 } 594 if( typeCol[i]==7 ){ 595 double r; 596 memcpy(&r, &v, sizeof(r)); 597 printf("%#g\n", r); 598 }else{ 599 printf("%lld\n", v); 600 } 601 }else{ 602 int ii, jj; 603 char zConst[32]; 604 if( (typeCol[i]&1)==0 ){ 605 zConst[0] = 'x'; 606 zConst[1] = '\''; 607 for(ii=2, jj=0; jj<szCol[i] && ii<24; jj++, ii+=2){ 608 sprintf(zConst+ii, "%02x", pData[jj]); 609 } 610 }else{ 611 zConst[0] = '\''; 612 for(ii=1, jj=0; jj<szCol[i] && ii<24; jj++, ii++){ 613 zConst[ii] = ISPRINT(pData[jj]) ? pData[jj] : '.'; 614 } 615 zConst[ii] = 0; 616 } 617 if( jj<szCol[i] ){ 618 memcpy(zConst+ii, "...'", 5); 619 }else{ 620 memcpy(zConst+ii, "'", 2); 621 } 622 printf("%s\n", zConst); 623 } 624 j = ofstCol[i] + szCol[i]; 625 } 626 } 627 if( j<nLocal ){ 628 printBytes(a, x+j, 0); 629 printf("... %lld bytes of content ...\n", nLocal-j); 630 } 631 if( nLocal<nPayload ){ 632 printBytes(a, x+nLocal, 4); 633 printf("overflow-page: %u\n", decodeInt32(x+nLocal)); 634 } 635 } 636 637 638 /* 639 ** Decode a btree page 640 */ 641 static void decode_btree_page( 642 unsigned char *a, /* Page content */ 643 int pgno, /* Page number */ 644 int hdrSize, /* Size of the page header. 0 or 100 */ 645 char *zArgs /* Flags to control formatting */ 646 ){ 647 const char *zType = "unknown"; 648 int nCell; 649 int i, j; 650 int iCellPtr; 651 int showCellContent = 0; 652 int showMap = 0; 653 int cellToDecode = -2; 654 char *zMap = 0; 655 switch( a[0] ){ 656 case 2: zType = "index interior node"; break; 657 case 5: zType = "table interior node"; break; 658 case 10: zType = "index leaf"; break; 659 case 13: zType = "table leaf"; break; 660 } 661 while( zArgs[0] ){ 662 switch( zArgs[0] ){ 663 case 'c': showCellContent = 1; break; 664 case 'm': showMap = 1; break; 665 case 'd': { 666 if( !ISDIGIT(zArgs[1]) ){ 667 cellToDecode = -1; 668 }else{ 669 cellToDecode = 0; 670 while( ISDIGIT(zArgs[1]) ){ 671 zArgs++; 672 cellToDecode = cellToDecode*10 + zArgs[0] - '0'; 673 } 674 } 675 break; 676 } 677 } 678 zArgs++; 679 } 680 nCell = a[3]*256 + a[4]; 681 iCellPtr = (a[0]==2 || a[0]==5) ? 12 : 8; 682 if( cellToDecode>=nCell ){ 683 printf("Page %d has only %d cells\n", pgno, nCell); 684 return; 685 } 686 printf("Header on btree page %d:\n", pgno); 687 print_decode_line(a, 0, 1, zType); 688 print_decode_line(a, 1, 2, "Offset to first freeblock"); 689 print_decode_line(a, 3, 2, "Number of cells on this page"); 690 print_decode_line(a, 5, 2, "Offset to cell content area"); 691 print_decode_line(a, 7, 1, "Fragmented byte count"); 692 if( a[0]==2 || a[0]==5 ){ 693 print_decode_line(a, 8, 4, "Right child"); 694 } 695 if( cellToDecode==(-2) && nCell>0 ){ 696 printf(" key: lx=left-child n=payload-size r=rowid\n"); 697 } 698 if( showMap ){ 699 zMap = sqlite3_malloc(g.pagesize); 700 memset(zMap, '.', g.pagesize); 701 memset(zMap, '1', hdrSize); 702 memset(&zMap[hdrSize], 'H', iCellPtr); 703 memset(&zMap[hdrSize+iCellPtr], 'P', 2*nCell); 704 } 705 for(i=0; i<nCell; i++){ 706 int cofst = iCellPtr + i*2; 707 char *zDesc; 708 i64 n; 709 710 cofst = a[cofst]*256 + a[cofst+1]; 711 n = describeCell(a[0], &a[cofst-hdrSize], showCellContent, &zDesc); 712 if( showMap ){ 713 char zBuf[30]; 714 memset(&zMap[cofst], '*', (size_t)n); 715 zMap[cofst] = '['; 716 zMap[cofst+n-1] = ']'; 717 sprintf(zBuf, "%d", i); 718 j = (int)strlen(zBuf); 719 if( j<=n-2 ) memcpy(&zMap[cofst+1], zBuf, j); 720 } 721 if( cellToDecode==(-2) ){ 722 printf(" %03x: cell[%d] %s\n", cofst, i, zDesc); 723 }else if( cellToDecode==(-1) || cellToDecode==i ){ 724 decodeCell(a, pgno, i, hdrSize, cofst-hdrSize); 725 } 726 } 727 if( showMap ){ 728 printf("Page map: (H=header P=cell-index 1=page-1-header .=free-space)\n"); 729 for(i=0; i<g.pagesize; i+=64){ 730 printf(" %03x: %.64s\n", i, &zMap[i]); 731 } 732 sqlite3_free(zMap); 733 } 734 } 735 736 /* 737 ** Decode a freelist trunk page. 738 */ 739 static void decode_trunk_page( 740 u32 pgno, /* The page number */ 741 int detail, /* Show leaf pages if true */ 742 int recursive /* Follow the trunk change if true */ 743 ){ 744 u32 i; 745 u32 n; 746 unsigned char *a; 747 while( pgno>0 ){ 748 a = fileRead((pgno-1)*g.pagesize, g.pagesize); 749 printf("Decode of freelist trunk page %d:\n", pgno); 750 print_decode_line(a, 0, 4, "Next freelist trunk page"); 751 print_decode_line(a, 4, 4, "Number of entries on this page"); 752 if( detail ){ 753 n = decodeInt32(&a[4]); 754 for(i=0; i<n && i<g.pagesize/4; i++){ 755 u32 x = decodeInt32(&a[8+4*i]); 756 char zIdx[10]; 757 sprintf(zIdx, "[%d]", i); 758 printf(" %5s %7u", zIdx, x); 759 if( i%5==4 ) printf("\n"); 760 } 761 if( i%5!=0 ) printf("\n"); 762 } 763 if( !recursive ){ 764 pgno = 0; 765 }else{ 766 pgno = decodeInt32(&a[0]); 767 } 768 sqlite3_free(a); 769 } 770 } 771 772 /* 773 ** A short text comment on the use of each page. 774 */ 775 static char **zPageUse; 776 777 /* 778 ** Add a comment on the use of a page. 779 */ 780 static void page_usage_msg(u32 pgno, const char *zFormat, ...){ 781 va_list ap; 782 char *zMsg; 783 784 va_start(ap, zFormat); 785 zMsg = sqlite3_vmprintf(zFormat, ap); 786 va_end(ap); 787 if( pgno<=0 || pgno>g.mxPage ){ 788 printf("ERROR: page %d out of range 1..%u: %s\n", 789 pgno, g.mxPage, zMsg); 790 sqlite3_free(zMsg); 791 return; 792 } 793 if( zPageUse[pgno]!=0 ){ 794 printf("ERROR: page %d used multiple times:\n", pgno); 795 printf("ERROR: previous: %s\n", zPageUse[pgno]); 796 printf("ERROR: current: %s\n", zMsg); 797 sqlite3_free(zPageUse[pgno]); 798 } 799 zPageUse[pgno] = zMsg; 800 } 801 802 /* 803 ** Find overflow pages of a cell and describe their usage. 804 */ 805 static void page_usage_cell( 806 unsigned char cType, /* Page type */ 807 unsigned char *a, /* Cell content */ 808 u32 pgno, /* page containing the cell */ 809 int cellno /* Index of the cell on the page */ 810 ){ 811 int i; 812 int n = 0; 813 i64 nPayload; 814 i64 rowid; 815 i64 nLocal; 816 i = 0; 817 if( cType<=5 ){ 818 a += 4; 819 n += 4; 820 } 821 if( cType!=5 ){ 822 i = decodeVarint(a, &nPayload); 823 a += i; 824 n += i; 825 nLocal = localPayload(nPayload, cType); 826 }else{ 827 nPayload = nLocal = 0; 828 } 829 if( cType==5 || cType==13 ){ 830 i = decodeVarint(a, &rowid); 831 a += i; 832 n += i; 833 } 834 if( nLocal<nPayload ){ 835 u32 ovfl = decodeInt32(a+nLocal); 836 u32 cnt = 0; 837 while( ovfl && (cnt++)<g.mxPage ){ 838 page_usage_msg(ovfl, "overflow %d from cell %d of page %u", 839 cnt, cellno, pgno); 840 a = fileRead((ovfl-1)*(sqlite3_int64)g.pagesize, 4); 841 ovfl = decodeInt32(a); 842 sqlite3_free(a); 843 } 844 } 845 } 846 847 /* 848 ** True if the memory is all zeros 849 */ 850 static int allZero(unsigned char *a, int n){ 851 while( n && (a++)[0]==0 ){ n--; } 852 return n==0; 853 } 854 855 856 /* 857 ** Describe the usages of a b-tree page. 858 ** 859 ** If parent==0, then this is the root of a btree. If parent<0 then 860 ** this is an orphan page. 861 */ 862 static void page_usage_btree( 863 u32 pgno, /* Page to describe */ 864 u32 parent, /* Parent of this page. 0 for root pages */ 865 int idx, /* Which child of the parent */ 866 const char *zName /* Name of the table */ 867 ){ 868 unsigned char *a; 869 const char *zType = "corrupt node"; 870 int nCell; 871 int i; 872 int hdr = pgno==1 ? 100 : 0; 873 char zEntry[30]; 874 875 if( pgno<=0 || pgno>g.mxPage ) return; 876 a = fileRead((pgno-1)*g.pagesize, g.pagesize); 877 switch( a[hdr] ){ 878 case 0: { 879 if( allZero(a, g.pagesize) ){ 880 zType = "zeroed page"; 881 }else if( parent<0 ){ 882 return; 883 }else{ 884 zType = "corrupt node"; 885 } 886 break; 887 } 888 case 2: zType = "interior node of index"; break; 889 case 5: zType = "interior node of table"; break; 890 case 10: zType = "leaf of index"; break; 891 case 13: zType = "leaf of table"; break; 892 default: { 893 if( parent<0 ) return; 894 zType = "corrupt node"; 895 } 896 } 897 nCell = a[hdr+3]*256 + a[hdr+4]; 898 if( nCell==1 ){ 899 sqlite3_snprintf(sizeof(zEntry),zEntry,"1 row"); 900 }else{ 901 sqlite3_snprintf(sizeof(zEntry),zEntry,"%d rows", nCell); 902 } 903 if( parent>0 ){ 904 page_usage_msg(pgno, "%s [%s], child %d of page %d, %s", 905 zType, zName, idx, parent, zEntry); 906 }else if( parent==0 ){ 907 page_usage_msg(pgno, "root %s [%s], %s", zType, zName, zEntry); 908 }else{ 909 page_usage_msg(pgno, "orphaned %s, %s", zType, zEntry); 910 } 911 if( a[hdr]==2 || a[hdr]==5 ){ 912 int cellstart = hdr+12; 913 u32 child; 914 for(i=0; i<nCell; i++){ 915 u32 ofst; 916 917 ofst = cellstart + i*2; 918 ofst = a[ofst]*256 + a[ofst+1]; 919 child = decodeInt32(a+ofst); 920 page_usage_btree(child, pgno, i, zName); 921 } 922 child = decodeInt32(a+cellstart-4); 923 page_usage_btree(child, pgno, i, zName); 924 } 925 if( a[hdr]==2 || a[hdr]==10 || a[hdr]==13 ){ 926 int cellstart = hdr + 8 + 4*(a[hdr]<=5); 927 for(i=0; i<nCell; i++){ 928 int ofst; 929 ofst = cellstart + i*2; 930 ofst = a[ofst]*256 + a[ofst+1]; 931 page_usage_cell(a[hdr], a+ofst, pgno, i); 932 } 933 } 934 sqlite3_free(a); 935 } 936 937 /* 938 ** Determine page usage by the freelist 939 */ 940 static void page_usage_freelist(u32 pgno){ 941 unsigned char *a; 942 int cnt = 0; 943 int i; 944 int n; 945 int iNext; 946 int parent = 1; 947 948 while( pgno>0 && pgno<=g.mxPage && (cnt++)<g.mxPage ){ 949 page_usage_msg(pgno, "freelist trunk #%d child of %d", cnt, parent); 950 a = fileRead((pgno-1)*g.pagesize, g.pagesize); 951 iNext = decodeInt32(a); 952 n = decodeInt32(a+4); 953 for(i=0; i<n; i++){ 954 int child = decodeInt32(a + (i*4+8)); 955 page_usage_msg(child, "freelist leaf, child %d of trunk page %d", 956 i, pgno); 957 } 958 sqlite3_free(a); 959 parent = pgno; 960 pgno = iNext; 961 } 962 } 963 964 /* 965 ** Determine pages used as PTRMAP pages 966 */ 967 static void page_usage_ptrmap(u8 *a){ 968 if( decodeInt32(a+52) ){ 969 int usable = g.pagesize - a[20]; 970 u64 pgno = 2; 971 int perPage = usable/5; 972 while( pgno<=g.mxPage ){ 973 page_usage_msg((u32)pgno, "PTRMAP page covering %llu..%llu", 974 pgno+1, pgno+perPage); 975 pgno += perPage + 1; 976 } 977 } 978 } 979 980 /* 981 ** Try to figure out how every page in the database file is being used. 982 */ 983 static void page_usage_report(const char *zPrg, const char *zDbName){ 984 u32 i, j; 985 int rc; 986 sqlite3 *db; 987 sqlite3_stmt *pStmt; 988 unsigned char *a; 989 char zQuery[200]; 990 991 /* Avoid the pathological case */ 992 if( g.mxPage<1 ){ 993 printf("empty database\n"); 994 return; 995 } 996 997 /* Open the database file */ 998 db = openDatabase(zPrg, zDbName); 999 1000 /* Set up global variables zPageUse[] and g.mxPage to record page 1001 ** usages */ 1002 zPageUse = sqlite3_malloc64( sizeof(zPageUse[0])*(g.mxPage+1) ); 1003 if( zPageUse==0 ) out_of_memory(); 1004 memset(zPageUse, 0, sizeof(zPageUse[0])*(g.mxPage+1)); 1005 1006 /* Discover the usage of each page */ 1007 a = fileRead(0, 100); 1008 page_usage_freelist(decodeInt32(a+32)); 1009 page_usage_ptrmap(a); 1010 sqlite3_free(a); 1011 page_usage_btree(1, 0, 0, "sqlite_schema"); 1012 sqlite3_exec(db, "PRAGMA writable_schema=ON", 0, 0, 0); 1013 for(j=0; j<2; j++){ 1014 sqlite3_snprintf(sizeof(zQuery), zQuery, 1015 "SELECT type, name, rootpage FROM SQLITE_MASTER WHERE rootpage" 1016 " ORDER BY rowid %s", j?"DESC":""); 1017 rc = sqlite3_prepare_v2(db, zQuery, -1, &pStmt, 0); 1018 if( rc==SQLITE_OK ){ 1019 while( sqlite3_step(pStmt)==SQLITE_ROW ){ 1020 u32 pgno = (u32)sqlite3_column_int64(pStmt, 2); 1021 page_usage_btree(pgno, 0, 0, (const char*)sqlite3_column_text(pStmt,1)); 1022 } 1023 }else{ 1024 printf("ERROR: cannot query database: %s\n", sqlite3_errmsg(db)); 1025 } 1026 rc = sqlite3_finalize(pStmt); 1027 if( rc==SQLITE_OK ) break; 1028 } 1029 sqlite3_close(db); 1030 1031 /* Print the report and free memory used */ 1032 for(i=1; i<=g.mxPage; i++){ 1033 if( zPageUse[i]==0 ) page_usage_btree(i, -1, 0, 0); 1034 printf("%5u: %s\n", i, zPageUse[i] ? zPageUse[i] : "???"); 1035 sqlite3_free(zPageUse[i]); 1036 } 1037 sqlite3_free(zPageUse); 1038 zPageUse = 0; 1039 } 1040 1041 /* 1042 ** Try to figure out how every page in the database file is being used. 1043 */ 1044 static void ptrmap_coverage_report(const char *zDbName){ 1045 u64 pgno; 1046 unsigned char *aHdr; 1047 unsigned char *a; 1048 int usable; 1049 int perPage; 1050 int i; 1051 1052 /* Avoid the pathological case */ 1053 if( g.mxPage<1 ){ 1054 printf("empty database\n"); 1055 return; 1056 } 1057 1058 /* Make sure PTRMAPs are used in this database */ 1059 aHdr = fileRead(0, 100); 1060 if( aHdr[55]==0 ){ 1061 printf("database does not use PTRMAP pages\n"); 1062 return; 1063 } 1064 usable = g.pagesize - aHdr[20]; 1065 perPage = usable/5; 1066 sqlite3_free(aHdr); 1067 printf("%5d: root of sqlite_schema\n", 1); 1068 for(pgno=2; pgno<=g.mxPage; pgno += perPage+1){ 1069 printf("%5llu: PTRMAP page covering %llu..%llu\n", pgno, 1070 pgno+1, pgno+perPage); 1071 a = fileRead((pgno-1)*g.pagesize, usable); 1072 for(i=0; i+5<=usable && pgno+1+i/5<=g.mxPage; i+=5){ 1073 const char *zType = "???"; 1074 u32 iFrom = decodeInt32(&a[i+1]); 1075 switch( a[i] ){ 1076 case 1: zType = "b-tree root page"; break; 1077 case 2: zType = "freelist page"; break; 1078 case 3: zType = "first page of overflow"; break; 1079 case 4: zType = "later page of overflow"; break; 1080 case 5: zType = "b-tree non-root page"; break; 1081 } 1082 printf("%5llu: %s, parent=%u\n", pgno+1+i/5, zType, iFrom); 1083 } 1084 sqlite3_free(a); 1085 } 1086 } 1087 1088 /* 1089 ** Print a usage comment 1090 */ 1091 static void usage(const char *argv0){ 1092 fprintf(stderr, "Usage %s ?--uri? FILENAME ?args...?\n\n", argv0); 1093 fprintf(stderr, 1094 "switches:\n" 1095 " --raw Read db file directly, bypassing SQLite VFS\n" 1096 "args:\n" 1097 " dbheader Show database header\n" 1098 " pgidx Index of how each page is used\n" 1099 " ptrmap Show all PTRMAP page content\n" 1100 " NNN..MMM Show hex of pages NNN through MMM\n" 1101 " NNN..end Show hex of pages NNN through end of file\n" 1102 " NNNb Decode btree page NNN\n" 1103 " NNNbc Decode btree page NNN and show content\n" 1104 " NNNbm Decode btree page NNN and show a layout map\n" 1105 " NNNbdCCC Decode cell CCC on btree page NNN\n" 1106 " NNNt Decode freelist trunk page NNN\n" 1107 " NNNtd Show leaf freelist pages on the decode\n" 1108 " NNNtr Recursively decode freelist starting at NNN\n" 1109 ); 1110 } 1111 1112 int main(int argc, char **argv){ 1113 sqlite3_int64 szFile; 1114 unsigned char *zPgSz; 1115 const char *zPrg = argv[0]; /* Name of this executable */ 1116 char **azArg = argv; 1117 int nArg = argc; 1118 1119 /* Check for the "--uri" or "-uri" switch. */ 1120 if( nArg>1 ){ 1121 if( sqlite3_stricmp("-raw", azArg[1])==0 1122 || sqlite3_stricmp("--raw", azArg[1])==0 1123 ){ 1124 g.bRaw = 1; 1125 azArg++; 1126 nArg--; 1127 } 1128 } 1129 1130 if( nArg<2 ){ 1131 usage(zPrg); 1132 exit(1); 1133 } 1134 1135 fileOpen(zPrg, azArg[1]); 1136 szFile = fileGetsize(); 1137 1138 zPgSz = fileRead(16, 2); 1139 g.pagesize = zPgSz[0]*256 + zPgSz[1]*65536; 1140 if( g.pagesize==0 ) g.pagesize = 1024; 1141 sqlite3_free(zPgSz); 1142 1143 printf("Pagesize: %d\n", g.pagesize); 1144 g.mxPage = (u32)((szFile+g.pagesize-1)/g.pagesize); 1145 1146 printf("Available pages: 1..%u\n", g.mxPage); 1147 if( nArg==2 ){ 1148 u32 i; 1149 for(i=1; i<=g.mxPage; i++) print_page(i); 1150 }else{ 1151 int i; 1152 for(i=2; i<nArg; i++){ 1153 u32 iStart, iEnd; 1154 char *zLeft; 1155 if( strcmp(azArg[i], "dbheader")==0 ){ 1156 print_db_header(); 1157 continue; 1158 } 1159 if( strcmp(azArg[i], "pgidx")==0 ){ 1160 page_usage_report(zPrg, azArg[1]); 1161 continue; 1162 } 1163 if( strcmp(azArg[i], "ptrmap")==0 ){ 1164 ptrmap_coverage_report(azArg[1]); 1165 continue; 1166 } 1167 if( strcmp(azArg[i], "help")==0 ){ 1168 usage(zPrg); 1169 continue; 1170 } 1171 if( !ISDIGIT(azArg[i][0]) ){ 1172 fprintf(stderr, "%s: unknown option: [%s]\n", zPrg, azArg[i]); 1173 continue; 1174 } 1175 iStart = strtoul(azArg[i], &zLeft, 0); 1176 if( zLeft && strcmp(zLeft,"..end")==0 ){ 1177 iEnd = g.mxPage; 1178 }else if( zLeft && zLeft[0]=='.' && zLeft[1]=='.' ){ 1179 iEnd = strtol(&zLeft[2], 0, 0); 1180 }else if( zLeft && zLeft[0]=='b' ){ 1181 int ofst, nByte, hdrSize; 1182 unsigned char *a; 1183 if( iStart==1 ){ 1184 ofst = hdrSize = 100; 1185 nByte = g.pagesize-100; 1186 }else{ 1187 hdrSize = 0; 1188 ofst = (iStart-1)*g.pagesize; 1189 nByte = g.pagesize; 1190 } 1191 a = fileRead(ofst, nByte); 1192 decode_btree_page(a, iStart, hdrSize, &zLeft[1]); 1193 sqlite3_free(a); 1194 continue; 1195 }else if( zLeft && zLeft[0]=='t' ){ 1196 int detail = 0; 1197 int recursive = 0; 1198 int j; 1199 for(j=1; zLeft[j]; j++){ 1200 if( zLeft[j]=='r' ) recursive = 1; 1201 if( zLeft[j]=='d' ) detail = 1; 1202 } 1203 decode_trunk_page(iStart, detail, recursive); 1204 continue; 1205 }else{ 1206 iEnd = iStart; 1207 } 1208 if( iStart<1 || iEnd<iStart || iEnd>g.mxPage ){ 1209 fprintf(stderr, 1210 "Page argument should be LOWER?..UPPER?. Range 1 to %d\n", 1211 g.mxPage); 1212 exit(1); 1213 } 1214 while( iStart<=iEnd ){ 1215 print_page(iStart); 1216 iStart++; 1217 } 1218 } 1219 } 1220 fileClose(); 1221 return 0; 1222 } 1223