dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** Copyright (c) 2006 D. Richard Hipp
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** This program is free software; you can redistribute it and/or
dbda8d6ce9 2007-07-21       drh: ** modify it under the terms of the GNU General Public
dbda8d6ce9 2007-07-21       drh: ** License version 2 as published by the Free Software Foundation.
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** This program is distributed in the hope that it will be useful,
dbda8d6ce9 2007-07-21       drh: ** but WITHOUT ANY WARRANTY; without even the implied warranty of
dbda8d6ce9 2007-07-21       drh: ** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
dbda8d6ce9 2007-07-21       drh: ** General Public License for more details.
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** You should have received a copy of the GNU General Public
dbda8d6ce9 2007-07-21       drh: ** License along with this library; if not, write to the
dbda8d6ce9 2007-07-21       drh: ** Free Software Foundation, Inc., 59 Temple Place - Suite 330,
dbda8d6ce9 2007-07-21       drh: ** Boston, MA  02111-1307, USA.
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** Author contact information:
dbda8d6ce9 2007-07-21       drh: **   drh@hwaci.com
dbda8d6ce9 2007-07-21       drh: **   http://www.hwaci.com/drh/
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: *******************************************************************************
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** Procedures store and retrieve records from the repository
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: #include "config.h"
dbda8d6ce9 2007-07-21       drh: #include "content.h"
dbda8d6ce9 2007-07-21       drh: #include <assert.h>
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** Return the srcid associated with rid.  Or return 0 if rid is
dbda8d6ce9 2007-07-21       drh: ** original content and not a delta.
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: static int findSrcid(int rid, const char *zDb){
dbda8d6ce9 2007-07-21       drh:   Stmt qsrc;
dbda8d6ce9 2007-07-21       drh:   int srcid;
dbda8d6ce9 2007-07-21       drh:   if( zDb ){
dbda8d6ce9 2007-07-21       drh:     db_prepare(&qsrc, "SELECT srcid FROM %s.delta WHERE rid=%d", zDb, rid);
dbda8d6ce9 2007-07-21       drh:   }else{
dbda8d6ce9 2007-07-21       drh:     db_prepare(&qsrc, "SELECT srcid FROM delta WHERE rid=%d", rid);
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh:   if( db_step(&qsrc)==SQLITE_ROW ){
dbda8d6ce9 2007-07-21       drh:     srcid = db_column_int(&qsrc, 0);
dbda8d6ce9 2007-07-21       drh:   }else{
dbda8d6ce9 2007-07-21       drh:     srcid = 0;
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh:   db_finalize(&qsrc);
dbda8d6ce9 2007-07-21       drh:   return srcid;
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** Extract the content for ID rid and put it into the
dbda8d6ce9 2007-07-21       drh: ** uninitialized blob.
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: void content_get_from_db(int rid, Blob *pBlob, const char *zDb){
dbda8d6ce9 2007-07-21       drh:   Stmt q;
dbda8d6ce9 2007-07-21       drh:   int srcid;
dbda8d6ce9 2007-07-21       drh:   assert( g.repositoryOpen );
dbda8d6ce9 2007-07-21       drh:   srcid = findSrcid(rid, zDb);
dbda8d6ce9 2007-07-21       drh:   if( zDb ){
dbda8d6ce9 2007-07-21       drh:     db_prepare(&q,
dbda8d6ce9 2007-07-21       drh:        "SELECT content FROM %s.blob WHERE rid=%d AND size>=0",
dbda8d6ce9 2007-07-21       drh:        zDb, rid
dbda8d6ce9 2007-07-21       drh:     );
dbda8d6ce9 2007-07-21       drh:   }else{
dbda8d6ce9 2007-07-21       drh:     db_prepare(&q,
dbda8d6ce9 2007-07-21       drh:        "SELECT content FROM blob WHERE rid=%d AND size>=0",
dbda8d6ce9 2007-07-21       drh:        rid
dbda8d6ce9 2007-07-21       drh:     );
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh:   if( srcid ){
dbda8d6ce9 2007-07-21       drh:     Blob src;
dbda8d6ce9 2007-07-21       drh:     content_get_from_db(srcid, &src, zDb);
dbda8d6ce9 2007-07-21       drh:     if( db_step(&q)==SQLITE_ROW ){
dbda8d6ce9 2007-07-21       drh:       Blob delta;
dbda8d6ce9 2007-07-21       drh:       db_ephemeral_blob(&q, 0, &delta);
dbda8d6ce9 2007-07-21       drh:       blob_uncompress(&delta, &delta);
dbda8d6ce9 2007-07-21       drh:       blob_init(pBlob,0,0);
dbda8d6ce9 2007-07-21       drh:       blob_delta_apply(&src, &delta, pBlob);
dbda8d6ce9 2007-07-21       drh:       blob_reset(&delta);
dbda8d6ce9 2007-07-21       drh:     }else{
dbda8d6ce9 2007-07-21       drh:       blob_init(pBlob, 0, 0);
dbda8d6ce9 2007-07-21       drh:     }
dbda8d6ce9 2007-07-21       drh:     blob_reset(&src);
dbda8d6ce9 2007-07-21       drh:   }else{
dbda8d6ce9 2007-07-21       drh:     if( db_step(&q)==SQLITE_ROW ){
dbda8d6ce9 2007-07-21       drh:       db_ephemeral_blob(&q, 0, pBlob);
dbda8d6ce9 2007-07-21       drh:       blob_uncompress(pBlob, pBlob);
dbda8d6ce9 2007-07-21       drh:     }else{
dbda8d6ce9 2007-07-21       drh:       blob_init(pBlob,0, 0);
dbda8d6ce9 2007-07-21       drh:     }
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh:   db_finalize(&q);
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: void content_get(int rid, Blob *pBlob){
dbda8d6ce9 2007-07-21       drh:   content_get_from_db(rid, pBlob, 0);
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** COMMAND:  test-content-get
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** Extract a blob from the database and write it into a file.
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: void test_content_get_cmd(void){
dbda8d6ce9 2007-07-21       drh:   int rid;
dbda8d6ce9 2007-07-21       drh:   Blob content;
dbda8d6ce9 2007-07-21       drh:   const char *zFile;
dbda8d6ce9 2007-07-21       drh:   if( g.argc!=4 && g.argc!=3 ) usage("RECORDID ?FILENAME?");
dbda8d6ce9 2007-07-21       drh:   zFile = g.argc==4 ? g.argv[3] : "-";
dbda8d6ce9 2007-07-21       drh:   db_must_be_within_tree();
dbda8d6ce9 2007-07-21       drh:   rid = name_to_rid(g.argv[2]);
dbda8d6ce9 2007-07-21       drh:   content_get(rid, &content);
dbda8d6ce9 2007-07-21       drh:   blob_write_to_file(&content, zFile);
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** COMMAND:  test-content-rawget
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** Extract a blob from the database and write it into a file.  This
dbda8d6ce9 2007-07-21       drh: ** version does not expand the delta.
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: void test_content_rawget_cmd(void){
dbda8d6ce9 2007-07-21       drh:   int rid;
dbda8d6ce9 2007-07-21       drh:   Blob content;
dbda8d6ce9 2007-07-21       drh:   const char *zFile;
dbda8d6ce9 2007-07-21       drh:   if( g.argc!=4 && g.argc!=3 ) usage("RECORDID ?FILENAME?");
dbda8d6ce9 2007-07-21       drh:   zFile = g.argc==4 ? g.argv[3] : "-";
dbda8d6ce9 2007-07-21       drh:   db_must_be_within_tree();
dbda8d6ce9 2007-07-21       drh:   rid = name_to_rid(g.argv[2]);
dbda8d6ce9 2007-07-21       drh:   blob_zero(&content);
dbda8d6ce9 2007-07-21       drh:   db_blob(&content, "SELECT content FROM blob WHERE rid=%d", rid);
dbda8d6ce9 2007-07-21       drh:   blob_uncompress(&content, &content);
dbda8d6ce9 2007-07-21       drh:   blob_write_to_file(&content, zFile);
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** Write content into the database.  Return the record ID.  If the
dbda8d6ce9 2007-07-21       drh: ** content is already in the database, just return the record ID.
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** A phantom is written if pBlob==0.  If pBlob==0 then the UUID is set
dbda8d6ce9 2007-07-21       drh: ** to zUuid.  Otherwise zUuid is ignored.
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** If the record already exists but is a phantom, the pBlob content
dbda8d6ce9 2007-07-21       drh: ** is inserted and the phatom becomes a real record.
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: int content_put(Blob *pBlob, const char *zUuid){
dbda8d6ce9 2007-07-21       drh:   int size;
dbda8d6ce9 2007-07-21       drh:   int rid;
dbda8d6ce9 2007-07-21       drh:   Stmt s1;
dbda8d6ce9 2007-07-21       drh:   Blob cmpr;
dbda8d6ce9 2007-07-21       drh:   Blob hash;
dbda8d6ce9 2007-07-21       drh:   assert( g.repositoryOpen );
dbda8d6ce9 2007-07-21       drh:   if( pBlob==0 ){
dbda8d6ce9 2007-07-21       drh:     blob_init(&hash, zUuid, -1);
dbda8d6ce9 2007-07-21       drh:     size = -1;
dbda8d6ce9 2007-07-21       drh:   }else{
dbda8d6ce9 2007-07-21       drh:     sha1sum_blob(pBlob, &hash);
dbda8d6ce9 2007-07-21       drh:     size = blob_size(pBlob);
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh:   db_begin_transaction();
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh:   /* Check to see if the entry already exists and if it does whether
dbda8d6ce9 2007-07-21       drh:   ** or not the entry is a phantom
dbda8d6ce9 2007-07-21       drh:   */
dbda8d6ce9 2007-07-21       drh:   db_prepare(&s1, "SELECT rid, size FROM blob WHERE uuid=%B", &hash);
dbda8d6ce9 2007-07-21       drh:   if( db_step(&s1)==SQLITE_ROW ){
dbda8d6ce9 2007-07-21       drh:     rid = db_column_int(&s1, 0);
dbda8d6ce9 2007-07-21       drh:     if( db_column_int(&s1, 1)>=0 || pBlob==0 ){
dbda8d6ce9 2007-07-21       drh:       /* Either the entry is not a phantom or it is a phantom but we
dbda8d6ce9 2007-07-21       drh:       ** have no data with which to dephathomize it.  In either case,
dbda8d6ce9 2007-07-21       drh:       ** there is nothing for use to do other than return the RID. */
dbda8d6ce9 2007-07-21       drh:       db_finalize(&s1);
dbda8d6ce9 2007-07-21       drh:       db_end_transaction(0);
dbda8d6ce9 2007-07-21       drh:       return rid;
dbda8d6ce9 2007-07-21       drh:     }
dbda8d6ce9 2007-07-21       drh:   }else{
dbda8d6ce9 2007-07-21       drh:     rid = 0;  /* No entry with the same UUID currently exists */
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh:   db_finalize(&s1);
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh:   /* Construct a received-from ID if we do not already have one */
dbda8d6ce9 2007-07-21       drh:   if( g.rcvid==0 && pBlob!=0 ){
dbda8d6ce9 2007-07-21       drh:     db_multi_exec(
dbda8d6ce9 2007-07-21       drh:        "INSERT INTO rcvfrom(uid, mtime, nonce, ipaddr)"
dbda8d6ce9 2007-07-21       drh:        "VALUES(%d, julianday('now'), %Q, %Q)",
dbda8d6ce9 2007-07-21       drh:        g.userUid, g.zNonce, g.zIpAddr
dbda8d6ce9 2007-07-21       drh:     );
dbda8d6ce9 2007-07-21       drh:     g.rcvid = db_last_insert_rowid();
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh:   if( rid>0 ){
dbda8d6ce9 2007-07-21       drh:     /* We are just adding data to a phantom */
dbda8d6ce9 2007-07-21       drh:     assert( pBlob!=0 );
dbda8d6ce9 2007-07-21       drh:     db_prepare(&s1,
dbda8d6ce9 2007-07-21       drh:       "UPDATE blob SET rcvid=%d, size=%d, content=:data WHERE rid=%d",
75c476ccd1 2007-07-23       drh:        g.rcvid, size, rid
dbda8d6ce9 2007-07-21       drh:     );
dbda8d6ce9 2007-07-21       drh:     blob_compress(pBlob, &cmpr);
dbda8d6ce9 2007-07-21       drh:     db_bind_blob(&s1, ":data", &cmpr);
dbda8d6ce9 2007-07-21       drh:     db_exec(&s1);
dbda8d6ce9 2007-07-21       drh:   }else{
dbda8d6ce9 2007-07-21       drh:     /* We are creating a new entry */
dbda8d6ce9 2007-07-21       drh:     db_prepare(&s1,
dbda8d6ce9 2007-07-21       drh:       "INSERT INTO blob(rcvid,size,uuid,content)"
dbda8d6ce9 2007-07-21       drh:       "VALUES(%d,%d,'%s',:data)",
dbda8d6ce9 2007-07-21       drh:        g.rcvid, size, blob_str(&hash)
dbda8d6ce9 2007-07-21       drh:     );
dbda8d6ce9 2007-07-21       drh:     if( pBlob ){
dbda8d6ce9 2007-07-21       drh:       blob_compress(pBlob, &cmpr);
dbda8d6ce9 2007-07-21       drh:       db_bind_blob(&s1, ":data", &cmpr);
dbda8d6ce9 2007-07-21       drh:     }
dbda8d6ce9 2007-07-21       drh:     db_exec(&s1);
dbda8d6ce9 2007-07-21       drh:     rid = db_last_insert_rowid();
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh:   /* Finish the transaction and cleanup */
dbda8d6ce9 2007-07-21       drh:   db_finalize(&s1);
dbda8d6ce9 2007-07-21       drh:   db_end_transaction(0);
dbda8d6ce9 2007-07-21       drh:   blob_reset(&hash);
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh:   /* Make arrangements to verify that the data can be recovered
dbda8d6ce9 2007-07-21       drh:   ** before we commit */
dbda8d6ce9 2007-07-21       drh:   if( pBlob ){
dbda8d6ce9 2007-07-21       drh:     blob_reset(&cmpr);
dbda8d6ce9 2007-07-21       drh:     verify_before_commit(rid);
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh:   return rid;
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** COMMAND:  test-content-put
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** Extract a blob from the database and write it into a file.
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: void test_content_put_cmd(void){
dbda8d6ce9 2007-07-21       drh:   int rid;
dbda8d6ce9 2007-07-21       drh:   Blob content;
dbda8d6ce9 2007-07-21       drh:   if( g.argc!=3 ) usage("FILENAME");
dbda8d6ce9 2007-07-21       drh:   db_must_be_within_tree();
dbda8d6ce9 2007-07-21       drh:   user_select();
dbda8d6ce9 2007-07-21       drh:   blob_read_from_file(&content, g.argv[2]);
dbda8d6ce9 2007-07-21       drh:   rid = content_put(&content, 0);
dbda8d6ce9 2007-07-21       drh:   printf("inserted as record %d\n", rid);
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** Make sure the content at rid is the original content and is not a
dbda8d6ce9 2007-07-21       drh: ** delta.
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: void content_undelta(int rid){
dbda8d6ce9 2007-07-21       drh:   if( findSrcid(rid, 0)>0 ){
dbda8d6ce9 2007-07-21       drh:     Blob x;
dbda8d6ce9 2007-07-21       drh:     Stmt s;
dbda8d6ce9 2007-07-21       drh:     content_get(rid, &x);
dbda8d6ce9 2007-07-21       drh:     db_prepare(&s, "UPDATE blob SET content=:c WHERE rid=%d", rid);
dbda8d6ce9 2007-07-21       drh:     db_bind_blob(&s, ":c", &x);
dbda8d6ce9 2007-07-21       drh:     db_exec(&s);
dbda8d6ce9 2007-07-21       drh:     db_finalize(&s);
dbda8d6ce9 2007-07-21       drh:     db_multi_exec("DELETE FROM delta WHERE rid=%d", rid);
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** COMMAND:  test-content-undelta
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** Make sure the content at RECORDID is not a delta
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: void test_content_undelta_cmd(void){
dbda8d6ce9 2007-07-21       drh:   int rid;
dbda8d6ce9 2007-07-21       drh:   if( g.argc!=2 ) usage("RECORDID");
dbda8d6ce9 2007-07-21       drh:   db_must_be_within_tree();
dbda8d6ce9 2007-07-21       drh:   rid = atoi(g.argv[2]);
dbda8d6ce9 2007-07-21       drh:   content_undelta(rid);
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** Change the storage of rid so that it is a delta of srcid.
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** If rid is already a delta from some other place then no
dbda8d6ce9 2007-07-21       drh: ** conversion occurs and this is a no-op unless force==1.
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** If srcid is a delta that depends on rid, then srcid is
dbda8d6ce9 2007-07-21       drh: ** converted to undeltaed text.
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: void content_deltify(int rid, int srcid, int force){
dbda8d6ce9 2007-07-21       drh:   int s;
dbda8d6ce9 2007-07-21       drh:   Blob data, src, delta;
e3c529c2f0 2007-07-30 anonymous:   Stmt s1, s2;
dbda8d6ce9 2007-07-21       drh:   if( srcid==rid ) return;
dbda8d6ce9 2007-07-21       drh:   if( !force && findSrcid(rid, 0)>0 ) return;
dbda8d6ce9 2007-07-21       drh:   s = srcid;
dbda8d6ce9 2007-07-21       drh:   while( (s = findSrcid(s, 0))>0 ){
dbda8d6ce9 2007-07-21       drh:     if( s==rid ){
dbda8d6ce9 2007-07-21       drh:       content_undelta(srcid);
dbda8d6ce9 2007-07-21       drh:       break;
dbda8d6ce9 2007-07-21       drh:     }
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh:   content_get(srcid, &src);
dbda8d6ce9 2007-07-21       drh:   content_get(rid, &data);
dbda8d6ce9 2007-07-21       drh:   blob_delta_create(&src, &data, &delta);
dbda8d6ce9 2007-07-21       drh:   if( blob_size(&src)>=50 && blob_size(&data)>=50 &&
dbda8d6ce9 2007-07-21       drh:            blob_size(&delta) < blob_size(&data)*0.75 ){
dbda8d6ce9 2007-07-21       drh:     blob_compress(&delta, &delta);
e3c529c2f0 2007-07-30 anonymous:     db_prepare(&s1, "UPDATE blob SET content=:data WHERE rid=%d", rid);
e3c529c2f0 2007-07-30 anonymous:     db_prepare(&s2, "REPLACE INTO delta(rid,srcid)VALUES(%d,:sid)", rid);
e3c529c2f0 2007-07-30 anonymous:     db_bind_blob(&s1, ":data", &delta);
dbda8d6ce9 2007-07-21       drh:     db_bind_int(&s2, ":sid", srcid);
dbda8d6ce9 2007-07-21       drh:     db_begin_transaction();
dbda8d6ce9 2007-07-21       drh:     db_exec(&s1);
dbda8d6ce9 2007-07-21       drh:     db_exec(&s2);
dbda8d6ce9 2007-07-21       drh:     db_end_transaction(0);
e3c529c2f0 2007-07-30 anonymous:     db_finalize(&s1);
e3c529c2f0 2007-07-30 anonymous:     db_finalize(&s2);
dbda8d6ce9 2007-07-21       drh:   }
dbda8d6ce9 2007-07-21       drh:   blob_reset(&src);
dbda8d6ce9 2007-07-21       drh:   blob_reset(&data);
dbda8d6ce9 2007-07-21       drh:   blob_reset(&delta);
dbda8d6ce9 2007-07-21       drh:   verify_before_commit(rid);
dbda8d6ce9 2007-07-21       drh: }
dbda8d6ce9 2007-07-21       drh: 
dbda8d6ce9 2007-07-21       drh: /*
dbda8d6ce9 2007-07-21       drh: ** COMMAND:  test-content-deltify
dbda8d6ce9 2007-07-21       drh: **
dbda8d6ce9 2007-07-21       drh: ** Convert the content at RID into a delta from SRCID.
dbda8d6ce9 2007-07-21       drh: */
dbda8d6ce9 2007-07-21       drh: void test_content_deltify_cmd(void){
dbda8d6ce9 2007-07-21       drh:   if( g.argc!=5 ) usage("RID SRCID FORCE");
dbda8d6ce9 2007-07-21       drh:   db_must_be_within_tree();
dbda8d6ce9 2007-07-21       drh:   content_deltify(atoi(g.argv[2]), atoi(g.argv[3]), atoi(g.argv[4]));
dbda8d6ce9 2007-07-21       drh: }