Glue PySpark Command to run SQL

glue_sql.py

pre_query = "truncate table target_table"
post_query= "begin;delete from target_table using stage_table where stage_table.id = target_table.id ; insert into target_table select * from stage_table; drop table stage_table; end;"

connection_options_redshift = { 
    "preactions": pre_query,
    "dbtable": "stage_table", 
    "database": "redshiftdb",
    "postactions":post_query
}

datasink4 = glueContext.write_dynamic_frame.from_jdbc_conf(frame = datasource0, catalog_connection = "test_red", 
                                                           connection_options = connection_options_redshift,
                                                           redshift_tmp_dir = 's3://s3path', 
                                                           transformation_ctx = "datasink4")