We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
levkk
Learn more about funding links in repositories.
Report abuse
1 parent 0ab9d6a commit 8606b38Copy full SHA for 8606b38
pgdog/src/backend/pool/connection/buffer.rs
@@ -95,13 +95,17 @@ impl Buffer {
95
rd: &RowDescription,
96
) -> Result<(), super::Error> {
97
let buffer: VecDeque<DataRow> = self.buffer.drain(0..).collect();
98
- let aggregates = Aggregates::new(&buffer, rd, aggregate);
99
- let result = aggregates.aggregate()?;
100
-
101
- if !result.is_empty() {
102
- self.buffer = result;
103
- } else {
+ if aggregate.is_empty() {
104
self.buffer = buffer;
+ } else {
+ let aggregates = Aggregates::new(&buffer, rd, aggregate);
+ let result = aggregates.aggregate()?;
+
+ if !result.is_empty() {
105
+ self.buffer = result;
106
107
+ self.buffer = buffer;
108
+ }
109
}
110
111
Ok(())
0 commit comments