Removed copy of perftest

Author: bakwc

test_mysql_ch_replicator.py

@@ -728,88 +728,6 @@ def test_datetime_exception():
     binlog_replicator_runner.stop()
 
 
-def test_performance():
-    config_file = 'tests_config_perf.yaml'
-    num_records = 100000
-
-    cfg = config.Settings()
-    cfg.load(config_file)
-
-    mysql = mysql_api.MySQLApi(
-        database=None,
-        mysql_settings=cfg.mysql,
-    )
-
-    ch = clickhouse_api.ClickhouseApi(
-        database=TEST_DB_NAME,
-        clickhouse_settings=cfg.clickhouse,
-    )
-
-    prepare_env(cfg, mysql, ch)
-
-    mysql.execute(f'''
-    CREATE TABLE `{TEST_TABLE_NAME}` (
-        id int NOT NULL AUTO_INCREMENT,
-        name varchar(2048),
-        age int,
-        PRIMARY KEY (id)
-    ); 
-        ''')
-
-    binlog_replicator_runner = BinlogReplicatorRunner(cfg_file=config_file)
-    binlog_replicator_runner.run()
-
-    time.sleep(1)
-
-    mysql.execute(f"INSERT INTO `{TEST_TABLE_NAME}` (name, age) VALUES ('TEST_VALUE_1', 33);", commit=True)
-
-    def _get_last_insert_name():
-        record = get_last_insert_from_binlog(cfg=cfg, db_name=TEST_DB_NAME)
-        if record is None:
-            return None
-        return record[1].decode('utf-8')
-
-    assert_wait(lambda: _get_last_insert_name() == 'TEST_VALUE_1', retry_interval=0.5)
-
-    binlog_replicator_runner.stop()
-
-    time.sleep(1)
-
-    print("populating mysql data")
-
-    base_value = 'a' * 2000
-
-    for i in range(num_records):
-        if i % 2000 == 0:
-            print(f'populated {i} elements')
-        mysql.execute(
-            f"INSERT INTO `{TEST_TABLE_NAME}` (name, age) "
-            f"VALUES ('TEST_VALUE_{i}_{base_value}', {i});", commit=i % 20 == 0,
-        )
-#`replication-test_db`
-    mysql.execute(f"INSERT INTO `{TEST_TABLE_NAME}` (name, age) VALUES ('TEST_VALUE_FINAL', 0);", commit=True)
-
-    print("running db_replicator")
-    t1 = time.time()
-    binlog_replicator_runner = BinlogReplicatorRunner(cfg_file=config_file)
-    binlog_replicator_runner.run()
-
-    assert_wait(lambda: _get_last_insert_name() == 'TEST_VALUE_FINAL', retry_interval=0.5, max_wait_time=1000)
-    t2 = time.time()
-
-    binlog_replicator_runner.stop()
-
-    time_delta = t2 - t1
-    rps = num_records / time_delta
-
-    print('\n\n')
-    print("*****************************")
-    print("records per second:", int(rps))
-    print("total time (seconds):", round(time_delta, 2))
-    print("*****************************")
-    print('\n\n')
-
-
 
 def test_different_types_1():
     cfg = config.Settings()