EL4121 Embedded System / mbed-os

mbed-os

Dependents:   cobaLCDJoyMotor_Thread odometry_omni_3roda_v3 odometry_omni_3roda_v1 odometry_omni_3roda_v2 ... more

tools/test_db.py@0:b74591d5ab33, 2017-12-11 (annotated)

Committer:
be_bryan
Date:
Mon Dec 11 17:54:04 2017 +0000
Revision:
0:b74591d5ab33
motor ++

Who changed what in which revision?

UserRevisionLine numberNew contents of line
be_bryan 0:b74591d5ab33 1 """
be_bryan 0:b74591d5ab33 2 mbed SDK
be_bryan 0:b74591d5ab33 3 Copyright (c) 2011-2014 ARM Limited
be_bryan 0:b74591d5ab33 4
be_bryan 0:b74591d5ab33 5 Licensed under the Apache License, Version 2.0 (the "License");
be_bryan 0:b74591d5ab33 6 you may not use this file except in compliance with the License.
be_bryan 0:b74591d5ab33 7 You may obtain a copy of the License at
be_bryan 0:b74591d5ab33 8
be_bryan 0:b74591d5ab33 9 http://www.apache.org/licenses/LICENSE-2.0
be_bryan 0:b74591d5ab33 10
be_bryan 0:b74591d5ab33 11 Unless required by applicable law or agreed to in writing, software
be_bryan 0:b74591d5ab33 12 distributed under the License is distributed on an "AS IS" BASIS,
be_bryan 0:b74591d5ab33 13 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
be_bryan 0:b74591d5ab33 14 See the License for the specific language governing permissions and
be_bryan 0:b74591d5ab33 15 limitations under the License.
be_bryan 0:b74591d5ab33 16
be_bryan 0:b74591d5ab33 17 Author: Przemyslaw Wirkus <Przemyslaw.Wirkus@arm.com>
be_bryan 0:b74591d5ab33 18 """
be_bryan 0:b74591d5ab33 19
be_bryan 0:b74591d5ab33 20 import re
be_bryan 0:b74591d5ab33 21 import json
be_bryan 0:b74591d5ab33 22
be_bryan 0:b74591d5ab33 23
be_bryan 0:b74591d5ab33 24 class BaseDBAccess():
be_bryan 0:b74591d5ab33 25 """ Class used to connect with test database and store test results
be_bryan 0:b74591d5ab33 26 """
be_bryan 0:b74591d5ab33 27 def __init__(self):
be_bryan 0:b74591d5ab33 28 self.db_object = None
be_bryan 0:b74591d5ab33 29 self.db_type = None
be_bryan 0:b74591d5ab33 30 # Connection credentials
be_bryan 0:b74591d5ab33 31 self.host = None
be_bryan 0:b74591d5ab33 32 self.user = None
be_bryan 0:b74591d5ab33 33 self.passwd = None
be_bryan 0:b74591d5ab33 34 self.db = None
be_bryan 0:b74591d5ab33 35
be_bryan 0:b74591d5ab33 36 # Test Suite DB scheme (table names)
be_bryan 0:b74591d5ab33 37 self.TABLE_BUILD_ID = 'mtest_build_id'
be_bryan 0:b74591d5ab33 38 self.TABLE_BUILD_ID_STATUS = 'mtest_build_id_status'
be_bryan 0:b74591d5ab33 39 self.TABLE_BUILD_ID_TYPE = 'mtest_build_id_type'
be_bryan 0:b74591d5ab33 40 self.TABLE_TARGET = 'mtest_target'
be_bryan 0:b74591d5ab33 41 self.TABLE_TEST_ENTRY = 'mtest_test_entry'
be_bryan 0:b74591d5ab33 42 self.TABLE_TEST_ID = 'mtest_test_id'
be_bryan 0:b74591d5ab33 43 self.TABLE_TEST_RESULT = 'mtest_test_result'
be_bryan 0:b74591d5ab33 44 self.TABLE_TEST_TYPE = 'mtest_test_type'
be_bryan 0:b74591d5ab33 45 self.TABLE_TOOLCHAIN = 'mtest_toolchain'
be_bryan 0:b74591d5ab33 46 # Build ID status PKs
be_bryan 0:b74591d5ab33 47 self.BUILD_ID_STATUS_STARTED = 1 # Started
be_bryan 0:b74591d5ab33 48 self.BUILD_ID_STATUS_IN_PROGRESS = 2 # In Progress
be_bryan 0:b74591d5ab33 49 self.BUILD_ID_STATUS_COMPLETED = 3 #Completed
be_bryan 0:b74591d5ab33 50 self.BUILD_ID_STATUS_FAILED = 4 # Failed
be_bryan 0:b74591d5ab33 51 # Build ID type PKs
be_bryan 0:b74591d5ab33 52 self.BUILD_ID_TYPE_TEST = 1 # Test
be_bryan 0:b74591d5ab33 53 self.BUILD_ID_TYPE_BUILD_ONLY = 2 # Build Only
be_bryan 0:b74591d5ab33 54
be_bryan 0:b74591d5ab33 55 def get_hostname(self):
be_bryan 0:b74591d5ab33 56 """ Useful when creating build_id in database
be_bryan 0:b74591d5ab33 57 Function returns (hostname, uname) which can be used as (build_id_name, build_id_desc)
be_bryan 0:b74591d5ab33 58 """
be_bryan 0:b74591d5ab33 59 # Get hostname from socket
be_bryan 0:b74591d5ab33 60 import socket
be_bryan 0:b74591d5ab33 61 hostname = socket.gethostbyaddr(socket.gethostname())[0]
be_bryan 0:b74591d5ab33 62 # Get uname from platform resources
be_bryan 0:b74591d5ab33 63 import platform
be_bryan 0:b74591d5ab33 64 uname = json.dumps(platform.uname())
be_bryan 0:b74591d5ab33 65 return (hostname, uname)
be_bryan 0:b74591d5ab33 66
be_bryan 0:b74591d5ab33 67 def get_db_type(self):
be_bryan 0:b74591d5ab33 68 """ Returns database type. E.g. 'mysql', 'sqlLite' etc.
be_bryan 0:b74591d5ab33 69 """
be_bryan 0:b74591d5ab33 70 return self.db_type
be_bryan 0:b74591d5ab33 71
be_bryan 0:b74591d5ab33 72 def detect_database(self, verbose=False):
be_bryan 0:b74591d5ab33 73 """ detect database and return VERION data structure or string (verbose=True)
be_bryan 0:b74591d5ab33 74 """
be_bryan 0:b74591d5ab33 75 return None
be_bryan 0:b74591d5ab33 76
be_bryan 0:b74591d5ab33 77 def parse_db_connection_string(self, str):
be_bryan 0:b74591d5ab33 78 """ Parsing SQL DB connection string. String should contain:
be_bryan 0:b74591d5ab33 79 - DB Name, user name, password, URL (DB host), name
be_bryan 0:b74591d5ab33 80 Function should return tuple with parsed (db_type, username, password, host, db_name) or None if error
be_bryan 0:b74591d5ab33 81
be_bryan 0:b74591d5ab33 82 (db_type, username, password, host, db_name) = self.parse_db_connection_string(db_url)
be_bryan 0:b74591d5ab33 83
be_bryan 0:b74591d5ab33 84 E.g. connection string: 'mysql://username:password@127.0.0.1/db_name'
be_bryan 0:b74591d5ab33 85 """
be_bryan 0:b74591d5ab33 86 result = None
be_bryan 0:b74591d5ab33 87 if type(str) == type(''):
be_bryan 0:b74591d5ab33 88 PATTERN = '^([\w]+)://([\w]+):([\w]*)@(.*)/([\w]+)'
be_bryan 0:b74591d5ab33 89 result = re.match(PATTERN, str)
be_bryan 0:b74591d5ab33 90 if result is not None:
be_bryan 0:b74591d5ab33 91 result = result.groups() # Tuple (db_name, host, user, passwd, db)
be_bryan 0:b74591d5ab33 92 return result # (db_type, username, password, host, db_name)
be_bryan 0:b74591d5ab33 93
be_bryan 0:b74591d5ab33 94 def is_connected(self):
be_bryan 0:b74591d5ab33 95 """ Returns True if we are connected to database
be_bryan 0:b74591d5ab33 96 """
be_bryan 0:b74591d5ab33 97 pass
be_bryan 0:b74591d5ab33 98
be_bryan 0:b74591d5ab33 99 def connect(self, host, user, passwd, db):
be_bryan 0:b74591d5ab33 100 """ Connects to DB and returns DB object
be_bryan 0:b74591d5ab33 101 """
be_bryan 0:b74591d5ab33 102 pass
be_bryan 0:b74591d5ab33 103
be_bryan 0:b74591d5ab33 104 def connect_url(self, db_url):
be_bryan 0:b74591d5ab33 105 """ Connects to database using db_url (database url parsing),
be_bryan 0:b74591d5ab33 106 store host, username, password, db_name
be_bryan 0:b74591d5ab33 107 """
be_bryan 0:b74591d5ab33 108 pass
be_bryan 0:b74591d5ab33 109
be_bryan 0:b74591d5ab33 110 def reconnect(self):
be_bryan 0:b74591d5ab33 111 """ Reconnects to DB and returns DB object using stored host name,
be_bryan 0:b74591d5ab33 112 database name and credentials (user name and password)
be_bryan 0:b74591d5ab33 113 """
be_bryan 0:b74591d5ab33 114 pass
be_bryan 0:b74591d5ab33 115
be_bryan 0:b74591d5ab33 116 def disconnect(self):
be_bryan 0:b74591d5ab33 117 """ Close DB connection
be_bryan 0:b74591d5ab33 118 """
be_bryan 0:b74591d5ab33 119 pass
be_bryan 0:b74591d5ab33 120
be_bryan 0:b74591d5ab33 121 def escape_string(self, str):
be_bryan 0:b74591d5ab33 122 """ Escapes string so it can be put in SQL query between quotes
be_bryan 0:b74591d5ab33 123 """
be_bryan 0:b74591d5ab33 124 pass
be_bryan 0:b74591d5ab33 125
be_bryan 0:b74591d5ab33 126 def select_all(self, query):
be_bryan 0:b74591d5ab33 127 """ Execute SELECT query and get all results
be_bryan 0:b74591d5ab33 128 """
be_bryan 0:b74591d5ab33 129 pass
be_bryan 0:b74591d5ab33 130
be_bryan 0:b74591d5ab33 131 def insert(self, query, commit=True):
be_bryan 0:b74591d5ab33 132 """ Execute INSERT query, define if you want to commit
be_bryan 0:b74591d5ab33 133 """
be_bryan 0:b74591d5ab33 134 pass
be_bryan 0:b74591d5ab33 135
be_bryan 0:b74591d5ab33 136 def get_next_build_id(self, name, desc='', location='', type=None, status=None):
be_bryan 0:b74591d5ab33 137 """ Insert new build_id (DB unique build like ID number to send all test results)
be_bryan 0:b74591d5ab33 138 """
be_bryan 0:b74591d5ab33 139 pass
be_bryan 0:b74591d5ab33 140
be_bryan 0:b74591d5ab33 141 def get_table_entry_pk(self, table, column, value, update_db=True):
be_bryan 0:b74591d5ab33 142 """ Checks for entries in tables with two columns (<TABLE_NAME>_pk, <column>)
be_bryan 0:b74591d5ab33 143 If update_db is True updates table entry if value in specified column doesn't exist
be_bryan 0:b74591d5ab33 144 """
be_bryan 0:b74591d5ab33 145 pass
be_bryan 0:b74591d5ab33 146
be_bryan 0:b74591d5ab33 147 def update_table_entry(self, table, column, value):
be_bryan 0:b74591d5ab33 148 """ Updates table entry if value in specified column doesn't exist
be_bryan 0:b74591d5ab33 149 Locks table to perform atomic read + update
be_bryan 0:b74591d5ab33 150 """
be_bryan 0:b74591d5ab33 151 pass
be_bryan 0:b74591d5ab33 152
be_bryan 0:b74591d5ab33 153 def update_build_id_info(self, build_id, **kw):
be_bryan 0:b74591d5ab33 154 """ Update additional data inside build_id table
be_bryan 0:b74591d5ab33 155 Examples:
be_bryan 0:b74591d5ab33 156 db.update_build_is(build_id, _status_fk=self.BUILD_ID_STATUS_COMPLETED, _shuffle_seed=0.0123456789):
be_bryan 0:b74591d5ab33 157 """
be_bryan 0:b74591d5ab33 158 pass
be_bryan 0:b74591d5ab33 159
be_bryan 0:b74591d5ab33 160 def insert_test_entry(self, build_id, target, toolchain, test_type, test_id, test_result, test_time, test_timeout, test_loop, test_extra=''):
be_bryan 0:b74591d5ab33 161 """ Inserts test result entry to database. All checks regarding existing
be_bryan 0:b74591d5ab33 162 toolchain names in DB are performed.
be_bryan 0:b74591d5ab33 163 If some data is missing DB will be updated
be_bryan 0:b74591d5ab33 164 """
be_bryan 0:b74591d5ab33 165 pass