(final Iterator<? extends Object[]> iterator)
| 763 | } |
| 764 | |
| 765 | private final void executeSQL(final Iterator<? extends Object[]> iterator) { |
| 766 | configuration.dsl().connection(connection -> { |
| 767 | Configuration c = configuration.derive(new DefaultConnectionProvider(connection)); |
| 768 | |
| 769 | if (FALSE.equals(c.settings().isCachePreparedStatementInLoader())) { |
| 770 | executeSQL(iterator, c.dsl()); |
| 771 | } |
| 772 | |
| 773 | else { |
| 774 | try (CachedPSListener cache = new CachedPSListener()) { |
| 775 | executeSQL(iterator, c |
| 776 | .derive(combine(new DefaultExecuteListenerProvider(cache), c.executeListenerProviders())) |
| 777 | .dsl() |
| 778 | ); |
| 779 | } |
| 780 | } |
| 781 | }); |
| 782 | } |
| 783 | |
| 784 | private final void executeSQL(Iterator<? extends Object[]> iterator, DSLContext ctx) { |
| 785 | Object[] row = null; |
no test coverage detected