import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class Main {
  public static void main(String args[]) throws Exception {
    String connectionURL = "jdbc:mysql://localhost:3306/test";
    Class.forName("com.mysql.jdbc.Driver");
    Connection con = DriverManager.getConnection(connectionURL, "login", "password");
    Statement stmt = con.createStatement();
    stmt.execute("CREATE TRIGGER obs_update BEFORE UPDATE ON obs " //
        + "FOR EACH ROW "http://
        + "BEGIN "http://
        + "IF OLD.voided = 0 AND NEW.voided = 1 THEN "http://
        + "   DELETE FROM emp WHERE id = OLD.obs_id; "http://
        + "ELSE "http://
        + "   UPDATE emp SET emp.revision_token = NOW() "http://
        + "   WHERE NEW.id = emp.id; "http://
        + "END IF; "http://
        + "END;");
    con.close();
  }
}