@@ -102,12 +102,12 @@ pub fn saveInputsAndMarkOutputs(db: *sqlite.Db, inputs: std.ArrayList(Input)) !v
102
102
103
103
for (0.. inputs .items .len ) | i | {
104
104
const input = inputs .items [i ];
105
- const sql_input = "INSERT OR IGNORE INTO inputs(txid, reference_output_txid, reference_output_vout) VALUES(?, ?, ?)" ;
105
+ const sql_input = "INSERT OR IGNORE INTO inputs(txid, reference_output_txid, reference_output_vout) VALUES(?, ?, ?); " ;
106
106
var stmt_input = try db .prepare (sql_input );
107
107
defer stmt_input .deinit ();
108
108
try stmt_input .exec (.{}, .{ .txid = input .txid , .reference_output_txid = input .output_txid , .reference_output_vout = input .output_vout });
109
109
110
- const sql_output = "UPDATE outputs SET unspent = false WHERE txid = ? AND vout = ?" ;
110
+ const sql_output = "UPDATE outputs SET unspent = false WHERE txid = ? AND vout = ?; " ;
111
111
var stmt_output = try db .prepare (sql_output );
112
112
defer stmt_output .deinit ();
113
113
try stmt_output .exec (.{}, .{ .txid = input .output_txid , .vout = input .output_vout });
@@ -121,7 +121,7 @@ pub fn existsOutput(db: *sqlite.Db, txid: [64]u8, vout: u32) !bool {
121
121
var stmt = try db .prepare (sql );
122
122
defer stmt .deinit ();
123
123
const row = try stmt .one (struct { total : usize }, .{}, .{ .txid = txid , .vout = vout });
124
- return row .? .total > 1 ;
124
+ return row .? .total > 0 ;
125
125
}
126
126
127
127
pub fn getOutput (allocator : std.mem.Allocator , db : * sqlite.Db , txid : [64 ]u8 , vout : u32 ) ! ? Output {
0 commit comments