| 278 | |
| 279 | |
| 280 | SinkToStoragePtr StorageMySQL::write(const ASTPtr & /*query*/, const StorageMetadataPtr & metadata_snapshot, ContextPtr local_context, bool /*async_insert*/) |
| 281 | { |
| 282 | return std::make_shared<StorageMySQLSink>( |
| 283 | *this, |
| 284 | metadata_snapshot, |
| 285 | remote_database_name, |
| 286 | remote_table_name, |
| 287 | pool->get(), |
| 288 | local_context->getSettingsRef()[Setting::mysql_max_rows_to_insert]); |
| 289 | } |
| 290 | |
| 291 | StorageMySQL::Configuration StorageMySQL::processNamedCollectionResult( |
| 292 | const NamedCollection & named_collection, MySQLSettings & storage_settings, ContextPtr context_, bool require_table) |