| 1210 | } |
| 1211 | |
| 1212 | func ExampleConn_SendBatch() { |
| 1213 | ctx, cancel := context.WithTimeout(context.Background(), 120*time.Second) |
| 1214 | defer cancel() |
| 1215 | |
| 1216 | conn, err := pgx.Connect(ctx, os.Getenv("PGX_TEST_DATABASE")) |
| 1217 | if err != nil { |
| 1218 | fmt.Printf("Unable to establish connection: %v", err) |
| 1219 | return |
| 1220 | } |
| 1221 | |
| 1222 | batch := &pgx.Batch{} |
| 1223 | batch.Queue("select 1 + 1").QueryRow(func(row pgx.Row) error { |
| 1224 | var n int32 |
| 1225 | err := row.Scan(&n) |
| 1226 | if err != nil { |
| 1227 | return err |
| 1228 | } |
| 1229 | |
| 1230 | fmt.Println(n) |
| 1231 | |
| 1232 | return err |
| 1233 | }) |
| 1234 | |
| 1235 | batch.Queue("select 1 + 2").QueryRow(func(row pgx.Row) error { |
| 1236 | var n int32 |
| 1237 | err := row.Scan(&n) |
| 1238 | if err != nil { |
| 1239 | return err |
| 1240 | } |
| 1241 | |
| 1242 | fmt.Println(n) |
| 1243 | |
| 1244 | return err |
| 1245 | }) |
| 1246 | |
| 1247 | batch.Queue("select 2 + 3").QueryRow(func(row pgx.Row) error { |
| 1248 | var n int32 |
| 1249 | err := row.Scan(&n) |
| 1250 | if err != nil { |
| 1251 | return err |
| 1252 | } |
| 1253 | |
| 1254 | fmt.Println(n) |
| 1255 | |
| 1256 | return err |
| 1257 | }) |
| 1258 | |
| 1259 | err = conn.SendBatch(ctx, batch).Close() |
| 1260 | if err != nil { |
| 1261 | fmt.Printf("SendBatch error: %v", err) |
| 1262 | return |
| 1263 | } |
| 1264 | |
| 1265 | // Output: |
| 1266 | // 2 |
| 1267 | // 3 |
| 1268 | // 5 |
| 1269 | } |