def mergeEmtTag(tag){
    stage 'Connect to database'
    def db = [url:'jdbc:mysql://localhost:3306/jenkins', user:'jenkins_user', password:'xxxxxxxxxx', driver:'com.mysql.jdbc.Driver']
    def sql = Sql.newInstance(db.url, db.user, db.password, db.driver)

    stage 'Retrieve all EMTs'
    def rows = sql.rows("SELECT * FROM emts")
    sql.close()

    for ( i in rows ) {

        sh """
            if [ -d "${i.slug}" ]; then
                mkdir "${i.slug}"
            fi
        """
        dir("${slug}"){
            sh """
                git clone "git@bitbucket.org:xxxxxxxx/${row.slug}.git" .
                cd $slug
                git remote add upstream git@bitbucket.org:xxxxxxx/emt-master.git
                git checkout origin/master
                git fetch --tags upstream

                git merge "${tag}"

                if [ \$? -ne 0 ]; then
                    exit -1
                fi

                git branch --set-upstream-to=origin/master master
                git push -u origin master
             """
         }
    }
}