@@ -588,39 +588,40 @@ def test_add_common_creation_steps_to_queue(self):
588
588
'VALUES (%s, %s, %s)' )
589
589
590
590
sql_create_table = (
591
- 'CREATE TABLE qiita.prep_2 '
592
- '(sample_id varchar NOT NULL, str_column varchar, '
593
- 'run_prefix varchar, barcodesequence varchar, platform varchar, '
594
- 'linkerprimersequence varchar, '
595
- 'experiment_design_description varchar, '
596
- 'library_construction_protocol varchar)' )
591
+ 'CREATE TABLE qiita.prep_2 (sample_id varchar NOT NULL, '
592
+ 'barcodesequence varchar, experiment_design_description varchar, '
593
+ 'library_construction_protocol varchar, '
594
+ 'linkerprimersequence varchar, platform varchar, '
595
+ 'run_prefix varchar, str_column varchar)' )
597
596
598
597
sql_insert_dynamic = (
599
598
'INSERT INTO qiita.prep_2 '
600
- '(sample_id, str_column, run_prefix, barcodesequence, platform , '
601
- 'linkerprimersequence, experiment_design_description , '
602
- 'library_construction_protocol ) '
599
+ '(sample_id, barcodesequence, experiment_design_description , '
600
+ 'library_construction_protocol, linkerprimersequence, platform , '
601
+ 'run_prefix, str_column ) '
603
602
'VALUES (%s, %s, %s, %s, %s, %s, %s, %s)' )
604
603
605
604
sql_insert_dynamic_params_1 = (
606
- '2.SKB8.640193' , 'Value for sample 1' , 's_G1_L001_sequences' ,
607
- 'GTCCGCAAGTTA' , 'ILLUMINA' , 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' )
605
+ '2.SKB8.640193' , 'GTCCGCAAGTTA' , 'BBBB' , 'AAAA' ,
606
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L001_sequences' ,
607
+ 'Value for sample 1' )
608
608
sql_insert_dynamic_params_2 = (
609
- '2.SKD8.640184' , 'Value for sample 2' , 's_G1_L001_sequences' ,
610
- 'CGTAGAGCTCTC' , 'ILLUMINA' , 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' )
609
+ '2.SKD8.640184' , 'CGTAGAGCTCTC' , 'BBBB' , 'AAAA' ,
610
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L001_sequences' ,
611
+ 'Value for sample 2' )
611
612
612
613
exp = [
613
614
(sql_insert_common , sql_insert_common_params_1 ),
614
615
(sql_insert_common , sql_insert_common_params_2 ),
615
- (sql_insert_prep_columns , (2 , 'str_column' , 'varchar' )),
616
- (sql_insert_prep_columns , (2 , 'run_prefix' , 'varchar' )),
617
616
(sql_insert_prep_columns , (2 , 'barcodesequence' , 'varchar' )),
618
- (sql_insert_prep_columns , (2 , 'platform' , 'varchar' )),
619
- (sql_insert_prep_columns , (2 , 'linkerprimersequence' , 'varchar' )),
620
617
(sql_insert_prep_columns ,
621
618
(2 , 'experiment_design_description' , 'varchar' )),
622
619
(sql_insert_prep_columns ,
623
620
(2 , 'library_construction_protocol' , 'varchar' )),
621
+ (sql_insert_prep_columns , (2 , 'linkerprimersequence' , 'varchar' )),
622
+ (sql_insert_prep_columns , (2 , 'platform' , 'varchar' )),
623
+ (sql_insert_prep_columns , (2 , 'run_prefix' , 'varchar' )),
624
+ (sql_insert_prep_columns , (2 , 'str_column' , 'varchar' )),
624
625
(sql_create_table , None ),
625
626
(sql_insert_dynamic , sql_insert_dynamic_params_1 ),
626
627
(sql_insert_dynamic , sql_insert_dynamic_params_2 )]
@@ -800,17 +801,20 @@ def test_create(self):
800
801
# The new table hosts the correct values
801
802
obs = self .conn_handler .execute_fetchall (
802
803
"SELECT * FROM qiita.prep_2" )
803
- # sample_id, study_id, str_column, ebi_submission_accession,
804
- # run_prefix, barcodesequence, linkerprimersequence
805
- exp = [['1.SKB7.640196' , 'Value for sample 3' , 'ILLUMINA' ,
806
- 's_G1_L002_sequences' , 'CCTCTGAGAGCT' , None ,
807
- 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' ],
808
- ['1.SKB8.640193' , 'Value for sample 1' , 'ILLUMINA' ,
809
- 's_G1_L001_sequences' , 'GTCCGCAAGTTA' , None ,
810
- 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' ],
811
- ['1.SKD8.640184' , 'Value for sample 2' , 'ILLUMINA' ,
812
- 's_G1_L001_sequences' , 'CGTAGAGCTCTC' , None ,
813
- 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' ]]
804
+
805
+ # barcodesequence, ebi_submission_accession,
806
+ # experiment_design_description, library_construction_protocol,
807
+ # linkerprimersequence, platform, run_prefix, str_column
808
+ exp = [['1.SKB7.640196' , 'CCTCTGAGAGCT' , None , 'BBBB' , 'AAAA' ,
809
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L002_sequences' ,
810
+ 'Value for sample 3' ],
811
+ ['1.SKB8.640193' , 'GTCCGCAAGTTA' , None , 'BBBB' , 'AAAA' ,
812
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L001_sequences' ,
813
+ 'Value for sample 1' ],
814
+ ['1.SKD8.640184' , 'CGTAGAGCTCTC' , None , 'BBBB' , 'AAAA' ,
815
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L001_sequences' ,
816
+ 'Value for sample 2' ]]
817
+
814
818
self .assertEqual (sorted (obs ), sorted (exp ))
815
819
816
820
# prep and qiime files have been created
@@ -864,17 +868,18 @@ def test_create_already_prefixed_samples(self):
864
868
# The new table hosts the correct values
865
869
obs = self .conn_handler .execute_fetchall (
866
870
"SELECT * FROM qiita.prep_2" )
867
- # sample_id, study_id, str_column, ebi_submission_accession,
868
- # run_prefix, barcodesequence, linkerprimersequence
869
- exp = [['1.SKB7.640196' , 'Value for sample 3' , 'ILLUMINA' ,
870
- 's_G1_L002_sequences' , 'CCTCTGAGAGCT' , None ,
871
- 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' ],
872
- ['1.SKB8.640193' , 'Value for sample 1' , 'ILLUMINA' ,
873
- 's_G1_L001_sequences' , 'GTCCGCAAGTTA' , None ,
874
- 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' ],
875
- ['1.SKD8.640184' , 'Value for sample 2' , 'ILLUMINA' ,
876
- 's_G1_L001_sequences' , 'CGTAGAGCTCTC' , None ,
877
- 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' ]]
871
+ # barcodesequence, ebi_submission_accession,
872
+ # experiment_design_description, library_construction_protocol,
873
+ # linkerprimersequence, platform, run_prefix, str_column
874
+ exp = [['1.SKB7.640196' , 'CCTCTGAGAGCT' , None , 'BBBB' , 'AAAA' ,
875
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L002_sequences' ,
876
+ 'Value for sample 3' ],
877
+ ['1.SKB8.640193' , 'GTCCGCAAGTTA' , None , 'BBBB' , 'AAAA' ,
878
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L001_sequences' ,
879
+ 'Value for sample 1' ],
880
+ ['1.SKD8.640184' , 'CGTAGAGCTCTC' , None , 'BBBB' , 'AAAA' ,
881
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L001_sequences' ,
882
+ 'Value for sample 2' ]]
878
883
self .assertEqual (sorted (obs ), sorted (exp ))
879
884
880
885
# prep and qiime files have been created
@@ -965,17 +970,18 @@ def test_create_data_type_id(self):
965
970
# The new table hosts the correct values
966
971
obs = self .conn_handler .execute_fetchall (
967
972
"SELECT * FROM qiita.prep_2" )
968
- # sample_id, str_column, ebi_submission_accession,
969
- # run_prefix, barcodesequence, linkerprimersequence
970
- exp = [['1.SKB7.640196' , 'Value for sample 3' , 'ILLUMINA' ,
971
- 's_G1_L002_sequences' , 'CCTCTGAGAGCT' , None ,
972
- 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' ],
973
- ['1.SKB8.640193' , 'Value for sample 1' , 'ILLUMINA' ,
974
- 's_G1_L001_sequences' , 'GTCCGCAAGTTA' , None ,
975
- 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' ],
976
- ['1.SKD8.640184' , 'Value for sample 2' , 'ILLUMINA' ,
977
- 's_G1_L001_sequences' , 'CGTAGAGCTCTC' , None ,
978
- 'GTGCCAGCMGCCGCGGTAA' , 'BBBB' , 'AAAA' ]]
973
+ # barcodesequence, ebi_submission_accession,
974
+ # experiment_design_description, library_construction_protocol,
975
+ # linkerprimersequence, platform, run_prefix, str_column
976
+ exp = [['1.SKB7.640196' , 'CCTCTGAGAGCT' , None , 'BBBB' , 'AAAA' ,
977
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L002_sequences' ,
978
+ 'Value for sample 3' ],
979
+ ['1.SKB8.640193' , 'GTCCGCAAGTTA' , None , 'BBBB' , 'AAAA' ,
980
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L001_sequences' ,
981
+ 'Value for sample 1' ],
982
+ ['1.SKD8.640184' , 'CGTAGAGCTCTC' , None , 'BBBB' , 'AAAA' ,
983
+ 'GTGCCAGCMGCCGCGGTAA' , 'ILLUMINA' , 's_G1_L001_sequences' ,
984
+ 'Value for sample 2' ]]
979
985
self .assertEqual (sorted (obs ), sorted (exp ))
980
986
981
987
def test_create_error (self ):
0 commit comments