Sequelize und WITH HOLD Cursor

Question

Ich versuche, Cursor Seitennummerierung mit Postgresql und Sequelize zu implementieren, habe ich mit Erfolg versucht, einen Cursor mit HOLD auf eine Transaktion und Abrufen von Daten aus ihm.

sequelize.transaction(function (t) { 

    const query = "DECLARE my_cur CURSOR WITH HOLD FOR SELECT foo, bar FROM x " + 
     "WHERE time=\'2016-09-16\'::date;" 

    return sequelize.query(query, {transaction: t}).spread(function (results,metadata) { 
     console.log("Cursor created!") 
    }); 

}).then(function (result) { 
    console.log(result) 
    console.log("Transaction commited") 
    sequelize.query("FETCH NEXT FROM my_cur").spread(function (results,metadata) { 
     console.log("Fetching from previously created cursor:") 
     console.log(results) 
     console.log(metadata) 
    }).catch(function(err){ 
     console.log("Failed to fetch from cursor") 
     console.log(err) 
    }); 
}).catch(function (err) { 
    throw err 
    console.log("Failed to create a cursor") 
}); 

Wenn ich versuche, aus dem Cursor in einer anderen Sitzung zu holen erhalte ich:

FETCH NEXT FROM my_cur; 
ERROR: <<my_cur>> doesn't exist. 

Cursoren auch wenn WITH HOLD deklariert zerstört werden, nachdem eine Sitzung geschlossen und nicht zwischen den Sitzungen, meine Frage geteilt ist, wie Sequelize behandelt Sitzungen mit PostgreSQL, werde ich in der Lage sein, von diesem Cursor auf einem separaten API-Aufruf?

socket.on("fetch_next_page", function()){ 
    var cursor = socket.session.cursor 
    var pageSize = 10 
    sequelize.query("FETCH +"pageSize"+ FROM my_cur").spread(function (results,metadata) { 
      console.log("Fetching from previously created cursor:") 
      console.log(results) 
      socket.emit("page",results) 
      console.log(metadata) 
     }).catch(function(err){ 
      console.log("Failed to fetch from cursor") 
      console.log(err) 
     }); 
} 

Answer 1

Der einfachste Weg, eine Folge von Abfragen innerhalb der gleichen Sitzung auszuführen ist über eine Aufgabe oder Transaktion innerhalb pg-promise umgesetzt.

Siehe Tasks und Transactions.

Sie würden entweder Ihre Abfragen versprechen, wenn sie eine Abhängigkeit zwischen ihnen haben, oder sie als Stapel ausführen, wenn sie dies nicht tun.

Und wenn Sie N Zeiten innerhalb der Sitzung wiederholen müssen, wie FETCH bis bestimmte Bedingung aufrufen, können Sie auch Methode sequence verwenden.