equal
deleted
inserted
replaced
469 if (old_sessions.eq(sessions)) Library.Update.empty |
469 if (old_sessions.eq(sessions)) Library.Update.empty |
470 else Library.Update.make(old_sessions.data, sessions.data) |
470 else Library.Update.make(old_sessions.data, sessions.data) |
471 |
471 |
472 if (update.deletes) { |
472 if (update.deletes) { |
473 db.execute_statement( |
473 db.execute_statement( |
474 Pending.table.delete(sql = Generic.sql_where(names = update.delete))) |
474 Sessions.table.delete(sql = Generic.sql_where(names = update.delete))) |
475 } |
475 } |
476 |
476 |
477 if (update.inserts) { |
477 if (update.inserts) { |
478 db.execute_batch_statement(Sessions.table.insert(), batch = |
478 db.execute_batch_statement(Sessions.table.insert(), batch = |
479 for (name <- update.insert) yield { (stmt: SQL.Statement) => |
479 for (name <- update.insert) yield { (stmt: SQL.Statement) => |
771 ): Boolean = { |
771 ): Boolean = { |
772 val update = Library.Update.make(old_results, results) |
772 val update = Library.Update.make(old_results, results) |
773 |
773 |
774 if (update.deletes) { |
774 if (update.deletes) { |
775 db.execute_statement( |
775 db.execute_statement( |
776 Pending.table.delete(sql = Generic.sql_where(names = update.delete))) |
776 Results.table.delete(sql = Generic.sql_where(names = update.delete))) |
777 } |
777 } |
778 |
778 |
779 if (update.inserts) { |
779 if (update.inserts) { |
780 db.execute_batch_statement(Results.table.insert(), batch = |
780 db.execute_batch_statement(Results.table.insert(), batch = |
781 for (name <- update.insert) yield { (stmt: SQL.Statement) => |
781 for (name <- update.insert) yield { (stmt: SQL.Statement) => |