jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-25 02:09:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

updated benchmarks databases and scripts (#9597)

Browse Source
This commit is contained in:
andriikorotkov
2022-01-19 17:22:21 +02:00
committed by GitHub
parent 6990cc73ba
commit 208c14682d
5 changed files with 51 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
airbyte-integrations/connectors/source-mysql/src/test-performance/java/io/airbyte/integrations/source/mysql/MySqlRdsSourcePerformanceSecretTest.java
View File

@@ -67,9 +67,9 @@ public class MySqlRdsSourcePerformanceSecretTest extends AbstractSourcePerforman
@BeforeAll
public static void beforeAll() {
AbstractSourcePerformanceTest.testArgs = Stream.of(
Arguments.of("test1000tables240columns200recordsDb", "test1000tables240columns200recordsDb", 200, 240, 1000),
Arguments.of("newregular25tables50000records", "newregular25tables50000records", 50000, 8, 25),
Arguments.of("newsmall1000tableswith10000rows", "newsmall1000tableswith10000rows", 10000, 8, 1000));
Arguments.of("t1000_c240_r200", "t1000_c240_r200", 200, 240, 1000),
Arguments.of("t25_c8_r50k_s10kb", "t25_c8_r50k_s10kb", 50000, 8, 25),
Arguments.of("t1000_c8_r10k_s500b", "t1000_c8_r10k_s500b", 10000, 8, 1000));
}
}

8
airbyte-integrations/connectors/source-mysql/src/test-performance/sql/create_mysql_benchmarks.sql
View File

@@ -78,7 +78,7 @@ END while;
COMMIT;
SET
@insertTable = concat('insert into test (varchar1, varchar2, varchar3, varchar4, varchar5, longblobfield, timestampfield) values (');
@insertTable = concat('insert into test (varchar1, varchar2, varchar3, varchar4, varchar5, longtextfield, timestampfield) values (');
while @counter < @vmaxoneinsert do
SET
@@ -141,7 +141,7 @@ END while;
COMMIT;
SET
@insertTableLasted = concat('insert into test (varchar1, varchar2, varchar3, varchar4, varchar5, longblobfield, timestampfield) values (');
@insertTableLasted = concat('insert into test (varchar1, varchar2, varchar3, varchar4, varchar5, longtextfield, timestampfield) values (');
while @lastinsertcounter < @lastinsert do
SET
@@ -206,7 +206,7 @@ delimiter # CREATE
varchar3 VARCHAR(255),
varchar4 VARCHAR(255),
varchar5 VARCHAR(255),
longblobfield longblob,
longtextfield longtext,
timestampfield TIMESTAMP
) engine = innodb;
SET
@@ -277,4 +277,4 @@ DROP
PROCEDURE IF EXISTS table_copy;
ALTER TABLE
test RENAME test_0;
test RENAME test_0;