| 20 | |
| 21 | |
| 22 | ODBCBlockInputStream::ODBCBlockInputStream( |
| 23 | nanodbc::ConnectionHolderPtr connection_holder, const std::string & query_str, const Block & sample_block, const UInt64 max_block_size_) |
| 24 | : log(&Poco::Logger::get("ODBCBlockInputStream")) |
| 25 | , max_block_size{max_block_size_} |
| 26 | , query(query_str) |
| 27 | { |
| 28 | description.init(sample_block); |
| 29 | result = execute<nanodbc::result>(connection_holder, |
| 30 | [&](nanodbc::connection & connection) { return execute(connection, query); }); |
| 31 | } |
| 32 | |
| 33 | |
| 34 | Block ODBCBlockInputStream::readImpl() |