+++ /dev/null
-#!/usr/bin/env python
-#
-# Copyright (c) 2016 Samsung Electronics.Co.Ltd.
-#
-# This program is free software; you can redistribute it and/or modify it
-# under the terms of the GNU General Public License as published by the Free
-# Software Foundation; version 2 of the License
-#
-# This program is distributed in the hope that it will be useful, but
-# WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
-# or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
-# for more details.
-#
-"""
-BuildMonitor APIs
-
-1. Actions & Related files
- (1) gbs submit --------------- [job_submit.py]
- (2) [pre] packae build ------- [on OBS]
- (3) [pre] snapshot create ---- [job_pre_release_obs.py]
- (4) [pre] image creation ---- [job_imager.py][job_post_imager.py]
- (5) SR accept or reject ------ [job_request.py]
- (6) [post] package build ----- [on OBS]
- (7) [post] snapshot creation - [job_create_snapshot.py]
- (8) [post] image creation ---- [job_imager.py]
- (9) Completed
- * pre : pre build / post : post build
-
-2. function naming rules
-
-[ACTION]_for_[TABLE]
-
-ex) sr_submit_for_sr_status
-ACTION : gbs submit
-TABLE : sr_status
-
-3. db table list
-
-[SR parts] sr_stage | sr_status | sr_commit | sr_status_details
-[BUILD parts] build_snapshot | build_snapshot_package | build_image
-"""
-
-
-import os
-import sys
-import datetime
-import buildmonitor_db
-
-#===============================================================================
-# connect & disconnect db
-
-def bm_connect_db():
- buildmonitor_db.connect_db()
-
-def bm_disconnect_db():
- buildmonitor_db.disconnect_db()
-
-#===============================================================================
-# [job_submit.py]
-
-def sr_submit_for_sr_status(ter_git_tag):
- print '[%s] enter sr_submit_for_sr_status\n' % (__file__)
-
- # get curr_sr_status_id
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (ter_git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_sr_status_id(%s)\n' % (__file__, curr_sr_status_id)
-
- if curr_sr_status_id == 9876 or curr_sr_status_id == 0:
- query = "INSERT INTO sr_status (sr, status) VALUES(%s, %s)"
- query_data = (ter_git_tag, 'C')
- buildmonitor_db.do_query(query, query_data)
- else:
- print '[%s] Already existing sr_status_id(%s) skip INSERT sr_stage\n' \
- % (__file__, curr_sr_status_id)
-
-def sr_submit_for_sr_commit(mygit, git_tag, gerrit_project,
- gerrit_newrev, gerrit_account_name):
- print '[%s] enter sr_submit_for_sr_commit\n' % (__file__)
-
- commit_date, cd_err, cd_ret = mygit._git_inout('show', ['-s', '--format=%ci'])
- commit_msg, cm_err, cm_ret = mygit._git_inout('show', ['-s', '--format=%s'])
- submit_date, sd_err, sd_ret = mygit._git_inout('for-each-ref', \
- ['--count=1', '--sort=-taggerdate', '--format=%(taggerdate:iso)'])
- submit_msg, sm_err, sm_ret = mygit._git_inout('for-each-ref', \
- ['--count=1', '--sort=-taggerdate', '--format=%(subject)'])
- submitter, st_err, st_ret = mygit._git_inout('for-each-ref',\
- ['--count=1', '--sort=-taggerdate', '--format=%(taggeremail)'])
- #print '[%s] %s%s' % (__file__, commit_date, commit_msg)
- #print '[%s] %s%s%s' % (__file__, submit_date, submit_msg, submitter)
-
- # get current_sr_status_id (should be here, after sr_submit_for_sr_status)
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_sr_status_id(%s)\n' % (__file__, curr_sr_status_id)
-
- obs_pkg_name = os.path.basename(gerrit_project)
- ter_submitter = submitter.split('@')[0].strip('<')
- #print '[%s] ter_submitter(%s)' % (__file__, ter_submitter)
-
- query = "INSERT INTO sr_commit (sr_status_id, git_repository," \
- "obs_package_name, git_commit_id, git_commit_date, " \
- "git_commit_message, git_committer, sr_submit_date, " \
- "sr_submit_message, sr_submitter) " \
- "VALUES(%s, %s, %s, %s, %s, %s, %s, %s, %s, %s)"
- query_data = (curr_sr_status_id, gerrit_project, obs_pkg_name,
- gerrit_newrev, commit_date, commit_msg,
- gerrit_account_name, submit_date, submit_msg,
- ter_submitter)
- buildmonitor_db.do_query(query, query_data)
-
-def start_pre_build_for_sr_stage(git_tag, ter_start_datetime,
- ter_end_datetime, pre_build_project_id):
- print '[%s] enter start_pre_build_for_sr_stage\n' % (__file__)
-
- # get current_sr_status_id (should be here after sr_submit_for_sr_status)
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_sr_status_id(%s)\n' % (__file__, curr_sr_status_id)
-
- ### [1] end stage : SR submit
- info_stage_id = 1
- query = "UPDATE sr_stage SET stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND info_stage_id = %s AND build_project_id = %s"
- query_data = (ter_end_datetime, 'S', curr_sr_status_id, info_stage_id, pre_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- ### [2] start stage : [pre] package build
- ter_start_datetime = ter_end_datetime
- info_stage_id = 2
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, stage_start_time, " \
- "stage_status, build_project_id) VALUES(%s, %s, %s, %s, %s)"
- query_data = (curr_sr_status_id, info_stage_id, ter_start_datetime, 'R', pre_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def sr_submit_for_sr_stage(curr_sr_status_id, ter_start_datetime,
- ter_end_datetime, pre_build_project_id):
- print '[%s] enter sr_submit_for_sr_stage\n' % (__file__)
-
- ### [1] SR submit
- info_stage_id = 1
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, stage_start_time, " \
- "stage_end_time, stage_status, build_project_id) VALUES(%s, %s, %s, %s, %s, %s)"
- query_data = (curr_sr_status_id, info_stage_id, ter_start_datetime,
- ter_end_datetime, 'S', pre_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def package_build_for_sr_detail_sr_stage(git_tag, ter_start_datetime,
- ter_end_datetime, ter_src_project_lst):
- print '[%s] enter package_build_for_sr_detail_sr_stage\n' % (__file__)
-
- # get current_sr_status_id (should be here after sr_submit_for_sr_status)
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_sr_status_id(%s)\n' % (__file__, curr_sr_status_id)
-
- ### for sr_status_detail & sr_stage
- # ter_src_project_lst is needed for multi profile
- print '[%s] ter_src_project_lst(%s)\n' % (__file__, ter_src_project_lst)
- for ter_src_project in ter_src_project_lst:
- #print '[%s] ter_src_project(%s)\n' % (__file__, ter_src_project)
-
- # get info_project_id -> get pre_build_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (ter_src_project)
- info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (info_project_id)
- pre_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- print '[%s] info_project_id(%s), pre_build_project_id(%s)\n' \
- % (__file__, info_project_id, pre_build_project_id)
-
- # get sr_status_detail_id for checking group submit
- query = "SELECT id FROM sr_status_detail WHERE sr_status_id = %s " \
- "AND pre_build_project_id = %s"
- query_data = (curr_sr_status_id, pre_build_project_id)
- sr_status_detail_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] sr_status_detail_id(%s)\n' % (__file__, sr_status_detail_id)
-
- if sr_status_detail_id == 9876 or sr_status_detail_id == 0:
- # get pre_build_project_id
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (info_project_id)
- pre_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- ### for sr_status_detail
- query = "INSERT INTO sr_status_detail (sr_status_id, pre_build_project_id) " \
- "VALUES(%s, %s)"
- query_data = (curr_sr_status_id, pre_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- ### for sr_stage for multi profile
- # [1] start stage
- sr_submit_for_sr_stage(curr_sr_status_id, ter_start_datetime,
- ter_end_datetime, pre_build_project_id)
- # [1] end stage / [2] start stage
- start_pre_build_for_sr_stage(git_tag, ter_start_datetime,
- ter_end_datetime, pre_build_project_id)
- else:
- # clear the existing tables (sr_stage & build_snapshot)
- print '[%s] Already existing sr_status_id(%s)!! clear the related tables\n' \
- % (__file__, sr_status_detail_id)
- query = "DELETE FROM sr_stage WHERE sr_status_id = %s AND build_project_id = %s"
- query_data = (curr_sr_status_id, pre_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- # get build_snapshot_id for deleting build_snapshot_package & build_image
- query = "SELECT id FROM build_snapshot WHERE build_project_id = %s"
- query_data = (pre_build_project_id)
- build_snapshot_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # delete build_snapshot & build_snapshot_package & build_image
- query = "DELETE FROM build_snapshot WHERE build_project_id = %s"
- query_data = (pre_build_project_id)
- buildmonitor_db.do_query(query, query_data)
- query = "DELETE FROM build_snapshot_package WHERE build_snapshot_id = %s"
- query_data = (build_snapshot_id)
- buildmonitor_db.do_query(query, query_data)
- query = "DELETE FROM build_image WHERE build_snapshot_id = %s"
- query_data = (build_snapshot_id)
- buildmonitor_db.do_query(query, query_data)
-
- ### for sr_stage for multi profile
- # [1] start stage
- sr_submit_for_sr_stage(curr_sr_status_id, ter_start_datetime,
- ter_end_datetime, pre_build_project_id)
- # [1] end stage / [2] start stage
- start_pre_build_for_sr_stage(git_tag, ter_start_datetime,
- ter_end_datetime, pre_build_project_id)
-
-#===============================================================================
-# [job_pre_release_obs.py]
-
-def update_fail_status_for_sr_stage(project, ter_git_tag):
- print '[%s] enter update_fail_status_for_sr_stage\n' % (__file__)
-
- # get curr_sr_status_id
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (ter_git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_sr_status_id (%s)\n' % (__file__, curr_sr_status_id)
-
- # get curr_info_project_id -> get curr_build_project_id for multi profile
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- curr_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (curr_info_project_id)
- curr_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- ### [3] stage end : update fail status [pre] snapshot creation
- info_stage_id = 3
- query = "UPDATE sr_stage SET stage_status = %s WHERE sr_status_id = %s " \
- "AND info_stage_id = %s AND build_project_id = %s"
- query_data = ('F', curr_sr_status_id, info_stage_id, curr_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def start_pre_create_snapshot_for_sr_stage(project, ter_git_tag, ter_start_datetime):
- print '[%s] enter start_pre_create_snapshot_for_sr_stage\n' % (__file__)
-
- # get curr_sr_status_id
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (ter_git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get curr_info_project_id -> get curr_build_project_id for multi profile
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- curr_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (curr_info_project_id)
- curr_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get multi_build_status from build_target
- query = "SELECT status FROM build_target WHERE build_project_id = %s " \
- "AND last_flag = %s"
- query_data = (curr_build_project_id, 'Y')
- multi_build_status = buildmonitor_db.get_multi_values_from_query_data(query, query_data)
- print '[%s] multi_build_status(%s)\n' % (__file__, multi_build_status)
-
- # default 'S'
- info_stage_status = 'S'
- for each_build_status in multi_build_status:
- #print '[%s] each_build_status(%s)\n' % (__file__, each_build_status)
- if each_build_status[0] == 'F':
- info_stage_status = 'F'
- print '[%s] failed!! info_stage_status(%s)\n' % (__file__, info_stage_status)
-
- ### [2] stage end : [pre] package build
- info_stage_id = 2
- ter_end_datetime = ter_start_datetime
- query = "UPDATE sr_stage SET stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND info_stage_id = %s AND build_project_id = %s"
- query_data = (ter_end_datetime, info_stage_status, curr_sr_status_id,
- info_stage_id, curr_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- ### [3] stage start : [pre] snapshot creation
- info_stage_id = 3
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, stage_start_time, " \
- "stage_status, build_project_id) VALUES(%s, %s, %s, %s, %s)"
- query_data = (curr_sr_status_id, info_stage_id,
- ter_start_datetime, 'R', curr_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def start_pre_create_snapshot_for_build_snapshot(project, ter_start_datetime):
- print '[%s] enter start_pre_create_snapshot_for_build_snapshot\n' % (__file__)
-
- # get pre_info_project_id -> get pre_build_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- pre_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (pre_info_project_id)
- pre_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] pre_info_project_id(%s), pre_build_project_id(%s)\n' \
- # % (__file__, pre_info_project_id, pre_build_project_id)
-
- ### for build_snapshot
- query = "INSERT INTO build_snapshot (build_project_id, start_time, status) " \
- "VALUES(%s, %s, %s)"
- query_data = (pre_build_project_id, ter_start_datetime, 'R')
- buildmonitor_db.do_query(query, query_data)
-
-def create_snapshot_packages_for_build_snapshot_package(project, ter_snapshot_name,
- ter_repo, ter_arch, ter_pkg_urls_dic,
- base_url,base_path):
- print '[%s] enter create_snapshot_packages_for_build_snapshot_package\n' % (__file__)
-
- ter_pkg_url = ter_pkg_urls_dic[ter_arch]
- ter_pkg_dir = ter_pkg_url.replace(base_url, base_path) #http -> /srv/obs
- #print '[%s] ter_arch(%s), os.listdir(ter_pkg_dir)(%s)\n' \
- # % (__file__, ter_arch, os.listdir(ter_pkg_dir))
-
- if ter_arch == 'ia32':
- ter_arch = 'i686'
-
- # get rpm files
- ter_pkg_name_lst = []
- ter_pkg_mdate_lst = []
- ter_pkg_size_lst = []
- for root, dirs, files in os.walk(ter_pkg_dir):
- for each_file in files:
- if each_file.endswith(".rpm"):
- rpm_file_path = root + '/' + each_file
- rpm_file_mdate = os.path.getmtime(rpm_file_path)
- rpm_file_size = os.path.getsize(rpm_file_path)
- ter_pkg_name_lst.append(each_file)
- ter_pkg_mdate_lst.append(rpm_file_mdate)
- ter_pkg_size_lst.append(rpm_file_size)
- #print '[%s] rpm_file_path(%s), rpm_file_mdate(%s), rpm_file_size(%s)\n' \
- # % (__file__, rpm_file_path, rpm_file_mdate, rpm_file_size)
-
- # get pre_info_project_id -> get pre_build_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- pre_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (pre_info_project_id)
- pre_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] pre_info_project_id(%s), pre_build_project_id(%s)\n' \
- # % (__file__, pre_info_project_id, pre_build_project_id)
-
- # get curr_build_snapshot_id
- query = "SELECT id FROM build_snapshot WHERE build_project_id = %s"
- query_data = (pre_build_project_id)
- curr_build_snapshot_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_build_snapshot_id(%s)\n' % (__file__, curr_build_snapshot_id)
-
- for each_pkg_name, each_pkg_mdate, each_pkg_size in zip(ter_pkg_name_lst, ter_pkg_mdate_lst, ter_pkg_size_lst):
- timestamp = datetime.datetime.fromtimestamp(each_pkg_mdate)
- #print '[%s] each_pkg_name(%s), timestamp(%s), each_pkg_size(%s)\n' \
- # % (__file__, each_pkg_name, timestamp, each_pkg_size)
- query = "INSERT INTO build_snapshot_package (build_snapshot_id, repository, " \
- "arch, package_name, created_date, package_size, package_url) " \
- "VALUES(%s, %s, %s, %s, %s, %s, %s)"
- query_data = (curr_build_snapshot_id, ter_repo, ter_arch, each_pkg_name,
- timestamp, each_pkg_size, ter_pkg_url)
- buildmonitor_db.do_query(query, query_data)
-
-def end_pre_create_snapshot_for_sr_stage(project, ter_git_tag,
- ter_start_datetime, ter_end_datetime):
- print '[%s] enter end_pre_create_snapshot_for_sr_stage\n' % (__file__)
-
- # get curr_sr_status_id
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (ter_git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get curr_info_project_id -> get curr_build_project_id for multi profile
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- curr_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (curr_info_project_id)
- curr_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- ### [3] stage end : [pre] snapshot creation
- info_stage_id = 3
- query = "UPDATE sr_stage SET stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND info_stage_id = %s AND build_project_id = %s"
- query_data = (ter_end_datetime, 'S', curr_sr_status_id,
- info_stage_id, curr_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- ### [4] stage start : [pre] image creation
- info_stage_id = 4
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, stage_start_time, " \
- "stage_status, build_project_id) VALUES(%s, %s, %s, %s, %s)"
- query_data = (curr_sr_status_id, info_stage_id, ter_end_datetime,
- 'R', curr_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def end_pre_create_snapshot_for_build_snapshot(project, ter_snapshot_name,
- ter_snapshot_url, ter_end_datetime):
- print '[%s] enter end_pre_create_snapshot_for_build_snapshot\n' % (__file__)
-
- # get pre_info_project_id -> get pre_build_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- pre_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (pre_info_project_id)
- pre_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] pre_info_project_id(%s), pre_build_project_id(%s)\n' \
- # % (__file__, pre_info_project_id, pre_build_project_id)
-
- ### for build_snapshot
- query = "UPDATE build_snapshot SET snapshot_name = %s, snapshot_url = %s, " \
- "end_time = %s, status = %s WHERE build_project_id = %s"
- query_data = (ter_snapshot_name, ter_snapshot_url, ter_end_datetime,
- 'S', pre_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-#===============================================================================
-# [job_imager.py]
-
-def update_fail_create_image_for_sr_stage(fields, ter_start_datetime):
- print '[%s] enter update_fail_create_image_for_sr_stage\n' % (__file__)
-
- ter_prj_name = fields["project"]
- ter_split_data = fields["project"].split(':')[-1]
- ter_git_tag = 'submit/tizen/' + ter_split_data
- ter_url = os.path.join(fields.get('url_pub_base', ''),
- fields['repo_path'], fields['images_path'])
- #print '[%s] ter_prj_name(%s), ter_split_data(%s), ter_git_tag(%s), ter_url(%s)\n' \
- # % (__file__, ter_prj_name, ter_split_data, ter_git_tag, ter_url)
-
- ter_end_datetime = datetime.datetime.now()
-
- #if 'prerelease' in ter_url:
- if not ((ter_url.find("prerelease")) == -1):
-
- # [pre_build] get current_sr_status_id
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (ter_git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s][pre_build] info_stage_id(%s), query_data(%s), curr_sr_status_id(%s)\n' \
- # % (__file__, info_stage_id, query_data, curr_sr_status_id)
-
- # get curr_info_project_id -> get curr_build_project_id for multi profile
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (ter_prj_name)
- curr_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (curr_info_project_id)
- curr_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- ### [4] stage : update fail status for [pre] image creation
- info_stage_id = 4
- query = "UPDATE sr_stage SET stage_start_time = %s, stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND info_stage_id = %s AND build_project_id = %s"
- query_data = (ter_start_datetime, ter_end_datetime, 'F',
- curr_sr_status_id, info_stage_id, curr_build_project_id)
- buildmonitor_db.do_query(query, query_data)
- else:
- # get post_info_project_id -> get post_build_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (ter_prj_name)
- post_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project " \
- "WHERE info_project_id = %s ORDER BY id desc LIMIT 1"
- query_data = (post_info_project_id)
- post_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get curr_sr_status_id
- query = "SELECT sr_status_id FROM sr_status_detail WHERE post_build_project_id = %s"
- query_data = (post_build_project_id)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_sr_status_id(%s)\n' % (__file__, curr_sr_status_id)
-
- ### [8] stage : update fail status for [post] image creation
- info_stage_id = 8
- query = "UPDATE sr_stage SET stage_start_time = %s, stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND info_stage_id = %s AND build_project_id = %s"
- query_data = (ter_start_datetime, ter_end_datetime, 'F',
- curr_sr_status_id, info_stage_id, post_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def create_image_for_build_image(fields, ter_start_datetime,
- ter_end_datetime, build_id):
- print '[%s] enter create_image_for_build_image\n' % (__file__)
-
- ter_repository = fields['repo']
- ter_device_name = fields['name']
- ter_status = fields['status']
- ter_url = fields['url']
- #print '[%s] ter_repository(%s), ter_device_name(%s), ter_status(%s), ter_url(%s)\n' \
- # % (__file__, ter_repository, ter_device_name, ter_status, ter_url)
-
- ter_base_path = os.getenv('PATH_REPO_BASE')
- ter_img_url = os.path.join(ter_base_path, fields['repo_path'], fields['images_path'])
- ter_img_path = ter_img_url + '/' + build_id + '_' + ter_device_name + '.tar.gz'
- ter_img_size = os.path.getsize(ter_img_path)
- #print '[%s] ter_img_path(%s), ter_img_size(%s)\n' \
- # % (__file__, ter_img_path, ter_img_size)
-
- # get curr_build_snapshot_id
- query = "SELECT id FROM build_snapshot WHERE snapshot_name = %s"
- query_data = (build_id)
- curr_build_snapshot_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_build_snapshot_id(%s)\n' % (__file__, curr_build_snapshot_id)
-
- ### for build_image
- query = "INSERT INTO build_image (build_snapshot_id, repository, device_name, " \
- "start_time, end_time, status, image_size, image_url) " \
- "VALUES(%s, %s, %s, %s, %s, %s, %s, %s)"
- query_data = (curr_build_snapshot_id, ter_repository, ter_device_name,
- ter_start_datetime, ter_end_datetime,
- ter_status, ter_img_size, ter_url)
- buildmonitor_db.do_query(query, query_data)
-
-#===============================================================================
-# [job_post_image.py]
-
-def end_create_image_for_sr_stage(ter_start_datetime, project):
- print '[%s] enter end_create_image_for_sr_stage project(%s)\n' % (__file__, project)
-
- if project.startswith("home:prerelease:"):
- ter_end_datetime = datetime.datetime.now()
- ter_git_tag = project.split(":")[-3] + '/' + project.split(":")[-2] + '/' + project.split(":")[-1]
- #print '[%s] ter_git_tag(%s)\n' % (__file__, ter_git_tag)
-
- # [pre_build] get current_sr_status_id
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (ter_git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s][pre_build] query_data(%s), curr_sr_status_id(%s)\n' \
- # % (__file__, query_data, curr_sr_status_id)
-
- # get curr_info_project_id -> get curr_build_project_id for multi profile
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- curr_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (curr_info_project_id)
- curr_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- ### [4] stage : [pre] image creation
- info_stage_id = 4
- query = "UPDATE sr_stage SET stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND info_stage_id = %s AND build_project_id = %s"
- query_data = (ter_end_datetime, 'S',
- curr_sr_status_id, info_stage_id, curr_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-#===============================================================================
-# [job_request.py]
-
-def sr_accept_for_sr_stage(ter_src_prj_name, ter_target_prj_name,
- ter_start_datetime, ter_end_datetime, ter_git_tag):
- print '[%s] enter sr_accept_for_sr_stage\n' % (__file__)
-
- # get current_sr_status_id
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (ter_git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_sr_status_id(%s)\n' % (__file__, curr_sr_status_id)
-
- # get curr_info_project_id -> get curr_build_project_id for multi profile
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (ter_src_prj_name)
- curr_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (curr_info_project_id)
- curr_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- ### [5] stage : SR aceept
- info_stage_id = 5
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, " \
- "stage_start_time, stage_end_time, stage_status, build_project_id) " \
- "VALUES(%s, %s, %s, %s, %s, %s)"
- query_data = (curr_sr_status_id, info_stage_id,
- ter_start_datetime, ter_end_datetime, 'S', curr_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- # get curr_info_project_id -> get post_build_project_id for multi profile
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (ter_target_prj_name)
- curr_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project " \
- "WHERE info_project_id = %s ORDER BY id desc LIMIT 1"
- query_data = (curr_info_project_id)
- post_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- ### [6] stage start : [post] package build
- info_stage_id = 6
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, " \
- "stage_start_time, stage_status, build_project_id) " \
- "VALUES(%s, %s, %s, %s, %s)"
- query_data = (curr_sr_status_id, info_stage_id, ter_start_datetime,
- 'R', post_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def sr_reject_for_sr_stage(ter_src_prj_name, ter_start_datetime,
- ter_end_datetime, ter_git_tag):
- print '[%s] enter sr_reject_for_sr_stage\n' % (__file__)
-
- # get curr_sr_status_id
- query = "SELECT id FROM sr_status WHERE sr = %s"
- query_data = (ter_git_tag)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] curr_sr_status_id(%s)\n' % (__file__, curr_sr_status_id)
-
- # get curr_info_project_id -> get curr_build_project_id for multi profile
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (ter_src_prj_name)
- curr_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (curr_info_project_id)
- curr_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- ### [5] stage : SR reject
- info_stage_id = 5
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, stage_start_time, " \
- "stage_end_time, stage_status, build_project_id) " \
- "VALUES(%s, %s, %s, %s, %s, %s)"
- query_data = (curr_sr_status_id, info_stage_id, ter_start_datetime, ter_end_datetime,
- 'F', curr_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def sr_accept_reject_for_sr_status_detail(event_fields, ter_start_datetime,
- ter_end_datetime, ter_git_tag):
- print '[%s] enter sr_accept_reject_for_sr_status_detail\n' % (__file__)
-
- obs_req_no = event_fields['id']
- obs_req_comment = event_fields['comment']
- obs_req_date = ter_end_datetime
- obs_req_status = event_fields['state']
- obs_req_status = obs_req_status.upper()
- ter_src_prj_name = event_fields['sourceproject']
- ter_target_prj_name = event_fields['targetproject']
- #print '[%s] obs_req_no(%s), obs_req_comment(%s), obs_req_date(%s), obs_req_status(%s)\n' \
- # % (__file__, obs_req_no, obs_req_comment, obs_req_date, obs_req_status)
- #print '[%s] ter_src_prj_name(%s), ter_target_prj_name(%s), ter_git_tag(%s)\n' \
- # % (__file__, ter_src_prj_name, ter_target_prj_name, ter_git_tag)
-
- if obs_req_status == 'ACCEPTED':
- print '[%s][ACCEPTED] obs_req_status(%s)\n' % (__file__, obs_req_status)
-
- # get pre_info_project_id -> get pre_build_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (ter_src_prj_name) # should use ter_src_prj_name
- pre_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (pre_info_project_id)
- pre_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] pre_info_project_id(%d), pre_build_project_id(%s)\n' \
- # % (__file__, pre_info_project_id, pre_build_project_id)
-
- # get post_info_project_id -> get post_build_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (ter_target_prj_name)
- post_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project " \
- "WHERE info_project_id = %s ORDER BY id desc LIMIT 1"
- query_data = (post_info_project_id)
- post_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] post_info_project_id(%s), post_build_project_id(%s)\n' \
- # % (__file__, post_info_project_id, post_build_project_id)
-
- ### for sr_status_detail
- query = "UPDATE sr_status_detail SET post_build_project_id = %s, obs_request_no = %s, " \
- "obs_request_comment = %s, obs_request_date = %s, obs_request_status = %s " \
- "WHERE pre_build_project_id = %s"
- query_data = (post_build_project_id, obs_req_no, obs_req_comment,
- obs_req_date, obs_req_status, pre_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- ### for sr_stage (now can find the build_project_id of the target prj)
- sr_accept_for_sr_stage(ter_src_prj_name, ter_target_prj_name,
- ter_start_datetime, ter_end_datetime, ter_git_tag)
-
- elif obs_req_status == 'REVOKED' or obs_req_status == 'DECLINED':
- print '[%s][REVOKED or DECLINED] obs_req_status(%s)\n' \
- % (__file__, obs_req_status)
-
- # get info_project_id -> get pre_build_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (ter_src_prj_name)
- info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- query = "SELECT id FROM build_project WHERE info_project_id = %s"
- query_data = (info_project_id)
- pre_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- ### for sr_status_detail
- query = "UPDATE sr_status_detail SET obs_request_no = %s, " \
- "obs_request_comment = %s, obs_request_date = %s, obs_request_status = %s " \
- "WHERE pre_build_project_id = %s"
- query_data = (obs_req_no, obs_req_comment, obs_req_date,
- obs_req_status, pre_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- ### for sr_stage
- sr_reject_for_sr_stage(ter_src_prj_name, ter_start_datetime,
- ter_end_datetime, ter_git_tag)
-
-#===============================================================================
-# [job_create_snapshot.py]
-
-def update_fail_create_snapshot_for_sr_stage(project):
- print '[%s] enter update_fail_create_snapshot_for_sr_stage\n' % (__file__)
-
- # get post_info_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project) # Tizen:Mobile
- post_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get post_build_project_id
- query = "SELECT id FROM build_project " \
- "WHERE info_project_id = %s ORDER BY id desc LIMIT 1"
- query_data = (post_info_project_id)
- post_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get curr_sr_status_id
- query = "SELECT sr_status_id FROM sr_status_detail WHERE post_build_project_id = %s"
- query_data = (post_build_project_id)
- curr_sr_status_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] post_info_project_id(%s), post_build_project_id(%d), curr_sr_status_id(%s)\n' \
- # % (__file__, post_info_project_id, post_build_project_id, curr_sr_status_id)
-
- ### [7] stage : update fail status when failed
- ter_start_datetime = ter_end_datetime = datetime.datetime.now()
- query = "UPDATE sr_stage SET stage_start_time = %s, stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND build_project_id = %s"
- query_data = (ter_start_datetime, ter_end_datetime, 'F',
- curr_sr_status_id, post_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def start_create_snapshot_for_sr_stage(project, ter_start_datetime):
- print '[%s] enter start_create_snapshot_for_sr_stage\n' % (__file__)
-
- # get post_info_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project) # Tizen:Mobile
- post_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get post_build_project_id
- query = "SELECT id FROM build_project " \
- "WHERE info_project_id = %s ORDER BY id desc LIMIT 1"
- query_data = (post_info_project_id)
- post_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get multi_sr_status_id
- query = "SELECT sr_status_id FROM sr_status_detail WHERE post_build_project_id = %s"
- query_data = (post_build_project_id)
- multi_sr_status_id = buildmonitor_db.get_multi_values_from_query_data(query, query_data)
- #print '[%s] post_info_project_id(%s), post_build_project_id(%d), multi_sr_status_id(%s)\n' \
- # % (__file__, post_info_project_id, post_build_project_id, multi_sr_status_id)
-
- ### [6] end / [7/8] start : [post] snapshot creation
- for each_sr_status_id in multi_sr_status_id:
- print '[%s] each_sr_status_id(%s)\n' % (__file__, each_sr_status_id)
- info_stage_id = 6
- ter_end_datetime = datetime.datetime.now()
- query = "UPDATE sr_stage SET stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND info_stage_id = %s AND build_project_id = %s"
- query_data = (ter_end_datetime, 'S',
- each_sr_status_id[0], info_stage_id, post_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- info_stage_id = 7
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, " \
- "stage_start_time, stage_end_time, stage_status, build_project_id) " \
- "VALUES(%s, %s, %s, %s, %s, %s)"
- query_data = (each_sr_status_id[0], info_stage_id,
- ter_start_datetime, ter_end_datetime, 'R', post_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- info_stage_id = 8
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, " \
- "stage_start_time, stage_end_time, stage_status, build_project_id) " \
- "VALUES(%s, %s, %s, %s, %s, %s)"
- query_data = (each_sr_status_id[0], info_stage_id,
- ter_start_datetime, ter_end_datetime, 'R', post_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def start_create_snapshot_for_post_build_snapshot(project, ter_snapshot_name,
- ter_start_datetime):
- print '[%s] enter start_create_snapshot_for_post_build_snapshot\n' % (__file__)
-
- # get post_info_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- post_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get post_build_project_id
- query = "SELECT id FROM build_project " \
- "WHERE info_project_id = %s ORDER BY id desc LIMIT 1"
- query_data = (post_info_project_id)
- post_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] post_info_project_id(%s), post_build_project_id(%d)\n' \
- # % (__file__, post_info_project_id, post_build_project_id)
-
- # insert new post_build_project_id
- query = "INSERT INTO build_snapshot (build_project_id, snapshot_name, " \
- "start_time, status) VALUES(%s, %s, %s, %s)"
- query_data = (post_build_project_id, ter_snapshot_name, ter_start_datetime, 'R')
- buildmonitor_db.do_query(query, query_data)
-
-def create_snapshot_packages_for_post_build_snapshot_package(repo, project, ter_repo,
- ter_arch, base_path, snapshot):
- print '[%s] enter create_snapshot_packages_for_post_build_snapshot_package\n' % (__file__)
-
- if ter_arch == 'ia32':
- ter_arch = 'i686'
- ter_repo_dir = os.path.join(snapshot.path, "repos", ter_repo, "packages")
- #print '[%s] snapshot.path(%s), ter_repo(%s), ter_arch(%s)\n' \
- # % (__file__, snapshot.path, ter_repo, ter_arch)
- #print '[%s] ter_repo_dir(%s), os.listdir(ter_repo_dir)(%s)\n' \
- # % (__file__, ter_repo_dir, os.listdir(ter_repo_dir))
-
- ter_base_url = os.getenv("URL_PUBLIC_REPO_BASE")
- ter_pkg_url = ter_repo_dir.replace(base_path, ter_base_url)
- #print '[%s] ter_base_url(%s), base_path(%s), ter_pkg_url(%s)\n' \
- # % (__file__, ter_base_url, base_path, ter_pkg_url)
-
- # get rpm files
- ter_pkg_name_lst = []
- ter_pkg_mdate_lst = []
- ter_pkg_size_lst = []
- for root, dirs, files in os.walk(ter_repo_dir):
- #print '[%s] root(%s), dirs(%s), files(%s)\n' % (__file__, root, dirs, files)
- for each_file in files:
- if each_file.endswith(".rpm"):
- rpm_file_path = os.path.join(root, each_file)
- rpm_file_mdate = os.path.getmtime(rpm_file_path)
- rpm_file_size = os.path.getsize(rpm_file_path)
- ter_pkg_name_lst.append(each_file)
- ter_pkg_mdate_lst.append(rpm_file_mdate)
- ter_pkg_size_lst.append(rpm_file_size)
- # too much log
- #print '[%s] rpm_file_path(%s), rpm_file_mdate(%s), rpm_file_size(%s)\n' \
- # % (__file__, rpm_file_path, rpm_file_mdate, rpm_file_size)
-
- # get post_info_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- post_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] post_info_project_id (%s)\n' % (__file__, post_info_project_id)
-
- # get post_build_project_id
- query = "SELECT id FROM build_project " \
- "WHERE info_project_id = %s ORDER BY id desc LIMIT 1"
- query_data = (post_info_project_id)
- build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get curr_build_snapshot_id
- query = "SELECT id FROM build_snapshot WHERE build_project_id = %s"
- query_data = (build_project_id)
- curr_build_snapshot_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- for each_pkg_name, each_pkg_mdate, each_pkg_size in zip(ter_pkg_name_lst, ter_pkg_mdate_lst, ter_pkg_size_lst):
- timestamp = datetime.datetime.fromtimestamp(each_pkg_mdate)
- # post build
- #print '[%s] curr_build_snapshot_id(%s), each_pkg_name(%s), timestamp(%s), each_pkg_size(%s)\n' \
- # % (__file__, curr_build_snapshot_id, each_pkg_name, timestamp, each_pkg_size)
- query = "INSERT INTO build_snapshot_package (build_snapshot_id, repository, arch, " \
- "package_name, created_date, package_size, package_url) " \
- "VALUES(%s, %s, %s, %s, %s, %s, %s)"
- query_data = (curr_build_snapshot_id, ter_repo, ter_arch,
- each_pkg_name, timestamp, each_pkg_size, ter_pkg_url)
- buildmonitor_db.do_query(query, query_data)
-
-def end_create_snapshot_create_images_for_sr_stage(project, ter_start_datetime,
- ter_end_datetime):
- print '[%s] enter end_create_snapshot_create_images_for_sr_stage\n' % (__file__)
-
- ### [7/8/9] end : [post] snapshot creation / [post] image creation / Completed
- # get post_info_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project) # Tizen:Mobile
- post_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get post_build_project_id
- query = "SELECT id FROM build_project " \
- "WHERE info_project_id = %s ORDER BY id desc LIMIT 1"
- query_data = (post_info_project_id)
- post_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get multi_sr_status_id
- query = "SELECT sr_status_id FROM sr_status_detail WHERE post_build_project_id = %s"
- query_data = (post_build_project_id)
- multi_sr_status_id = buildmonitor_db.get_multi_values_from_query_data(query, query_data)
- #print '[%s] post_info_project_id(%s), post_build_project_id(%d), multi_sr_status_id(%s)\n' \
- # % (__file__, post_info_project_id, post_build_project_id, multi_sr_status_id)
-
- for each_sr_status_id in multi_sr_status_id:
- print '[%s] each_sr_status_id(%s)\n' % (__file__, each_sr_status_id)
-
- # change the state_status of previous stage from 'R' to 'S'
- info_stage_id = 7
- query = "UPDATE sr_stage SET stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND info_stage_id = %s AND build_project_id = %s"
- query_data = (ter_end_datetime, 'S',
- each_sr_status_id[0], info_stage_id, post_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- info_stage_id = 8
- query = "UPDATE sr_stage SET stage_end_time = %s, stage_status = %s " \
- "WHERE sr_status_id = %s AND info_stage_id = %s AND build_project_id = %s"
- query_data = (ter_end_datetime, 'S',
- each_sr_status_id[0], info_stage_id, post_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
- info_stage_id = 9
- ter_start_datetime = datetime.datetime.now()
- query = "INSERT INTO sr_stage (sr_status_id, info_stage_id, " \
- "stage_start_time, stage_end_time, stage_status, build_project_id) " \
- "VALUES(%s, %s, %s, %s, %s, %s)"
- query_data = (each_sr_status_id[0], info_stage_id,
- ter_start_datetime, ter_end_datetime, 'S', post_build_project_id)
- buildmonitor_db.do_query(query, query_data)
-
-def end_create_snapshot_for_post_build_snapshot(project, ter_start_datetime,
- ter_end_datetime, ter_snapshot_url,
- ter_snapshot_name):
- print '[%s] enter end_create_snapshot_for_post_build_snapshot\n' % (__file__)
-
- # get post_info_project_id
- query = "SELECT id FROM info_project WHERE project_name = %s"
- query_data = (project)
- post_info_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
-
- # get post_build_project_id
- query = "SELECT id FROM build_project " \
- "WHERE info_project_id = %s ORDER BY id desc LIMIT 1"
- query_data = (post_info_project_id)
- post_build_project_id = buildmonitor_db.get_value_from_query_data(query, query_data)
- #print '[%s] post_info_project_id(%s), post_build_project_id(%d)\n' \
- # % (__file__, post_info_project_id, post_build_project_id)
-
- # insert new post_build_project_id
- query = "UPDATE build_snapshot SET snapshot_url = %s, " \
- "end_time = %s, status = %s WHERE snapshot_name = %s"
- query_data = (ter_snapshot_url, ter_end_datetime, 'S', ter_snapshot_name)
- buildmonitor_db.do_query(query, query_data)
-#==================================================================================
-
-def main():
- """
- Script entry point.
- """
-
-if __name__ == '__main__':
- try:
- sys.exit(main(os.path.basename(sys.argv[1])))
- except LocalError, err:
- print err
- sys.exit(1)
projects / services / jenkins-scripts.git / commitdiff