5.2.1 - Updated I2C files
Dependents: mbed-TFT-example-NCS36510 mbed-Accelerometer-example-NCS36510 mbed-Accelerometer-example-NCS36510
tools/test_mysql.py@1:f30bdcd2b33b, 2017-02-27 (annotated)
- Committer:
- jacobjohnson
- Date:
- Mon Feb 27 17:45:05 2017 +0000
- Revision:
- 1:f30bdcd2b33b
- Parent:
- 0:098463de4c5d
changed the inputscale from 1 to 7 in analogin_api.c. This will need to be changed later, and accessed from the main level, but for now this allows the adc to read a value from 0 to 3.7V, instead of just up to 1V.;
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
group-onsemi | 0:098463de4c5d | 1 | """ |
group-onsemi | 0:098463de4c5d | 2 | mbed SDK |
group-onsemi | 0:098463de4c5d | 3 | Copyright (c) 2011-2014 ARM Limited |
group-onsemi | 0:098463de4c5d | 4 | |
group-onsemi | 0:098463de4c5d | 5 | Licensed under the Apache License, Version 2.0 (the "License"); |
group-onsemi | 0:098463de4c5d | 6 | you may not use this file except in compliance with the License. |
group-onsemi | 0:098463de4c5d | 7 | You may obtain a copy of the License at |
group-onsemi | 0:098463de4c5d | 8 | |
group-onsemi | 0:098463de4c5d | 9 | http://www.apache.org/licenses/LICENSE-2.0 |
group-onsemi | 0:098463de4c5d | 10 | |
group-onsemi | 0:098463de4c5d | 11 | Unless required by applicable law or agreed to in writing, software |
group-onsemi | 0:098463de4c5d | 12 | distributed under the License is distributed on an "AS IS" BASIS, |
group-onsemi | 0:098463de4c5d | 13 | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
group-onsemi | 0:098463de4c5d | 14 | See the License for the specific language governing permissions and |
group-onsemi | 0:098463de4c5d | 15 | limitations under the License. |
group-onsemi | 0:098463de4c5d | 16 | |
group-onsemi | 0:098463de4c5d | 17 | Author: Przemyslaw Wirkus <Przemyslaw.Wirkus@arm.com> |
group-onsemi | 0:098463de4c5d | 18 | """ |
group-onsemi | 0:098463de4c5d | 19 | |
group-onsemi | 0:098463de4c5d | 20 | import re |
group-onsemi | 0:098463de4c5d | 21 | import MySQLdb as mdb |
group-onsemi | 0:098463de4c5d | 22 | |
group-onsemi | 0:098463de4c5d | 23 | # Imports from TEST API |
group-onsemi | 0:098463de4c5d | 24 | from tools.test_db import BaseDBAccess |
group-onsemi | 0:098463de4c5d | 25 | |
group-onsemi | 0:098463de4c5d | 26 | |
group-onsemi | 0:098463de4c5d | 27 | class MySQLDBAccess(BaseDBAccess): |
group-onsemi | 0:098463de4c5d | 28 | """ Wrapper for MySQL DB access for common test suite interface |
group-onsemi | 0:098463de4c5d | 29 | """ |
group-onsemi | 0:098463de4c5d | 30 | def __init__(self): |
group-onsemi | 0:098463de4c5d | 31 | BaseDBAccess.__init__(self) |
group-onsemi | 0:098463de4c5d | 32 | self.DB_TYPE = 'mysql' |
group-onsemi | 0:098463de4c5d | 33 | |
group-onsemi | 0:098463de4c5d | 34 | def detect_database(self, verbose=False): |
group-onsemi | 0:098463de4c5d | 35 | """ detect database and return VERION data structure or string (verbose=True) |
group-onsemi | 0:098463de4c5d | 36 | """ |
group-onsemi | 0:098463de4c5d | 37 | query = 'SHOW VARIABLES LIKE "%version%"' |
group-onsemi | 0:098463de4c5d | 38 | rows = self.select_all(query) |
group-onsemi | 0:098463de4c5d | 39 | if verbose: |
group-onsemi | 0:098463de4c5d | 40 | result = [] |
group-onsemi | 0:098463de4c5d | 41 | for row in rows: |
group-onsemi | 0:098463de4c5d | 42 | result.append("\t%s: %s"% (row['Variable_name'], row['Value'])) |
group-onsemi | 0:098463de4c5d | 43 | result = "\n".join(result) |
group-onsemi | 0:098463de4c5d | 44 | else: |
group-onsemi | 0:098463de4c5d | 45 | result = rows |
group-onsemi | 0:098463de4c5d | 46 | return result |
group-onsemi | 0:098463de4c5d | 47 | |
group-onsemi | 0:098463de4c5d | 48 | def parse_db_connection_string(self, str): |
group-onsemi | 0:098463de4c5d | 49 | """ Parsing SQL DB connection string. String should contain: |
group-onsemi | 0:098463de4c5d | 50 | - DB Name, user name, password, URL (DB host), name |
group-onsemi | 0:098463de4c5d | 51 | Function should return tuple with parsed (host, user, passwd, db) or None if error |
group-onsemi | 0:098463de4c5d | 52 | E.g. connection string: 'mysql://username:password@127.0.0.1/db_name' |
group-onsemi | 0:098463de4c5d | 53 | """ |
group-onsemi | 0:098463de4c5d | 54 | result = BaseDBAccess().parse_db_connection_string(str) |
group-onsemi | 0:098463de4c5d | 55 | if result is not None: |
group-onsemi | 0:098463de4c5d | 56 | (db_type, username, password, host, db_name) = result |
group-onsemi | 0:098463de4c5d | 57 | if db_type != 'mysql': |
group-onsemi | 0:098463de4c5d | 58 | result = None |
group-onsemi | 0:098463de4c5d | 59 | return result |
group-onsemi | 0:098463de4c5d | 60 | |
group-onsemi | 0:098463de4c5d | 61 | def is_connected(self): |
group-onsemi | 0:098463de4c5d | 62 | """ Returns True if we are connected to database |
group-onsemi | 0:098463de4c5d | 63 | """ |
group-onsemi | 0:098463de4c5d | 64 | return self.db_object is not None |
group-onsemi | 0:098463de4c5d | 65 | |
group-onsemi | 0:098463de4c5d | 66 | def connect(self, host, user, passwd, db): |
group-onsemi | 0:098463de4c5d | 67 | """ Connects to DB and returns DB object |
group-onsemi | 0:098463de4c5d | 68 | """ |
group-onsemi | 0:098463de4c5d | 69 | try: |
group-onsemi | 0:098463de4c5d | 70 | self.db_object = mdb.connect(host=host, user=user, passwd=passwd, db=db) |
group-onsemi | 0:098463de4c5d | 71 | # Let's remember connection credentials |
group-onsemi | 0:098463de4c5d | 72 | self.db_type = self.DB_TYPE |
group-onsemi | 0:098463de4c5d | 73 | self.host = host |
group-onsemi | 0:098463de4c5d | 74 | self.user = user |
group-onsemi | 0:098463de4c5d | 75 | self.passwd = passwd |
group-onsemi | 0:098463de4c5d | 76 | self.db = db |
group-onsemi | 0:098463de4c5d | 77 | except mdb.Error, e: |
group-onsemi | 0:098463de4c5d | 78 | print "Error %d: %s"% (e.args[0], e.args[1]) |
group-onsemi | 0:098463de4c5d | 79 | self.db_object = None |
group-onsemi | 0:098463de4c5d | 80 | self.db_type = None |
group-onsemi | 0:098463de4c5d | 81 | self.host = None |
group-onsemi | 0:098463de4c5d | 82 | self.user = None |
group-onsemi | 0:098463de4c5d | 83 | self.passwd = None |
group-onsemi | 0:098463de4c5d | 84 | self.db = None |
group-onsemi | 0:098463de4c5d | 85 | |
group-onsemi | 0:098463de4c5d | 86 | def connect_url(self, db_url): |
group-onsemi | 0:098463de4c5d | 87 | """ Connects to database using db_url (database url parsing), |
group-onsemi | 0:098463de4c5d | 88 | store host, username, password, db_name |
group-onsemi | 0:098463de4c5d | 89 | """ |
group-onsemi | 0:098463de4c5d | 90 | result = self.parse_db_connection_string(db_url) |
group-onsemi | 0:098463de4c5d | 91 | if result is not None: |
group-onsemi | 0:098463de4c5d | 92 | (db_type, username, password, host, db_name) = result |
group-onsemi | 0:098463de4c5d | 93 | if db_type == self.DB_TYPE: |
group-onsemi | 0:098463de4c5d | 94 | self.connect(host, username, password, db_name) |
group-onsemi | 0:098463de4c5d | 95 | |
group-onsemi | 0:098463de4c5d | 96 | def reconnect(self): |
group-onsemi | 0:098463de4c5d | 97 | """ Reconnects to DB and returns DB object using stored host name, |
group-onsemi | 0:098463de4c5d | 98 | database name and credentials (user name and password) |
group-onsemi | 0:098463de4c5d | 99 | """ |
group-onsemi | 0:098463de4c5d | 100 | self.connect(self.host, self.user, self.passwd, self.db) |
group-onsemi | 0:098463de4c5d | 101 | |
group-onsemi | 0:098463de4c5d | 102 | def disconnect(self): |
group-onsemi | 0:098463de4c5d | 103 | """ Close DB connection |
group-onsemi | 0:098463de4c5d | 104 | """ |
group-onsemi | 0:098463de4c5d | 105 | if self.db_object: |
group-onsemi | 0:098463de4c5d | 106 | self.db_object.close() |
group-onsemi | 0:098463de4c5d | 107 | self.db_object = None |
group-onsemi | 0:098463de4c5d | 108 | self.db_type = None |
group-onsemi | 0:098463de4c5d | 109 | |
group-onsemi | 0:098463de4c5d | 110 | def escape_string(self, str): |
group-onsemi | 0:098463de4c5d | 111 | """ Escapes string so it can be put in SQL query between quotes |
group-onsemi | 0:098463de4c5d | 112 | """ |
group-onsemi | 0:098463de4c5d | 113 | con = self.db_object |
group-onsemi | 0:098463de4c5d | 114 | result = con.escape_string(str) |
group-onsemi | 0:098463de4c5d | 115 | return result if result else '' |
group-onsemi | 0:098463de4c5d | 116 | |
group-onsemi | 0:098463de4c5d | 117 | def select_all(self, query): |
group-onsemi | 0:098463de4c5d | 118 | """ Execute SELECT query and get all results |
group-onsemi | 0:098463de4c5d | 119 | """ |
group-onsemi | 0:098463de4c5d | 120 | con = self.db_object |
group-onsemi | 0:098463de4c5d | 121 | cur = con.cursor(mdb.cursors.DictCursor) |
group-onsemi | 0:098463de4c5d | 122 | cur.execute(query) |
group-onsemi | 0:098463de4c5d | 123 | rows = cur.fetchall() |
group-onsemi | 0:098463de4c5d | 124 | return rows |
group-onsemi | 0:098463de4c5d | 125 | |
group-onsemi | 0:098463de4c5d | 126 | def insert(self, query, commit=True): |
group-onsemi | 0:098463de4c5d | 127 | """ Execute INSERT query, define if you want to commit |
group-onsemi | 0:098463de4c5d | 128 | """ |
group-onsemi | 0:098463de4c5d | 129 | con = self.db_object |
group-onsemi | 0:098463de4c5d | 130 | cur = con.cursor() |
group-onsemi | 0:098463de4c5d | 131 | cur.execute(query) |
group-onsemi | 0:098463de4c5d | 132 | if commit: |
group-onsemi | 0:098463de4c5d | 133 | con.commit() |
group-onsemi | 0:098463de4c5d | 134 | return cur.lastrowid |
group-onsemi | 0:098463de4c5d | 135 | |
group-onsemi | 0:098463de4c5d | 136 | def get_next_build_id(self, name, desc='', location='', type=None, status=None): |
group-onsemi | 0:098463de4c5d | 137 | """ Insert new build_id (DB unique build like ID number to send all test results) |
group-onsemi | 0:098463de4c5d | 138 | """ |
group-onsemi | 0:098463de4c5d | 139 | if status is None: |
group-onsemi | 0:098463de4c5d | 140 | status = self.BUILD_ID_STATUS_STARTED |
group-onsemi | 0:098463de4c5d | 141 | |
group-onsemi | 0:098463de4c5d | 142 | if type is None: |
group-onsemi | 0:098463de4c5d | 143 | type = self.BUILD_ID_TYPE_TEST |
group-onsemi | 0:098463de4c5d | 144 | |
group-onsemi | 0:098463de4c5d | 145 | query = """INSERT INTO `%s` (%s_name, %s_desc, %s_location, %s_type_fk, %s_status_fk) |
group-onsemi | 0:098463de4c5d | 146 | VALUES ('%s', '%s', '%s', %d, %d)"""% (self.TABLE_BUILD_ID, |
group-onsemi | 0:098463de4c5d | 147 | self.TABLE_BUILD_ID, |
group-onsemi | 0:098463de4c5d | 148 | self.TABLE_BUILD_ID, |
group-onsemi | 0:098463de4c5d | 149 | self.TABLE_BUILD_ID, |
group-onsemi | 0:098463de4c5d | 150 | self.TABLE_BUILD_ID, |
group-onsemi | 0:098463de4c5d | 151 | self.TABLE_BUILD_ID, |
group-onsemi | 0:098463de4c5d | 152 | self.escape_string(name), |
group-onsemi | 0:098463de4c5d | 153 | self.escape_string(desc), |
group-onsemi | 0:098463de4c5d | 154 | self.escape_string(location), |
group-onsemi | 0:098463de4c5d | 155 | type, |
group-onsemi | 0:098463de4c5d | 156 | status) |
group-onsemi | 0:098463de4c5d | 157 | index = self.insert(query) # Provide inserted record PK |
group-onsemi | 0:098463de4c5d | 158 | return index |
group-onsemi | 0:098463de4c5d | 159 | |
group-onsemi | 0:098463de4c5d | 160 | def get_table_entry_pk(self, table, column, value, update_db=True): |
group-onsemi | 0:098463de4c5d | 161 | """ Checks for entries in tables with two columns (<TABLE_NAME>_pk, <column>) |
group-onsemi | 0:098463de4c5d | 162 | If update_db is True updates table entry if value in specified column doesn't exist |
group-onsemi | 0:098463de4c5d | 163 | """ |
group-onsemi | 0:098463de4c5d | 164 | # TODO: table buffering |
group-onsemi | 0:098463de4c5d | 165 | result = None |
group-onsemi | 0:098463de4c5d | 166 | table_pk = '%s_pk'% table |
group-onsemi | 0:098463de4c5d | 167 | query = """SELECT `%s` |
group-onsemi | 0:098463de4c5d | 168 | FROM `%s` |
group-onsemi | 0:098463de4c5d | 169 | WHERE `%s`='%s'"""% (table_pk, |
group-onsemi | 0:098463de4c5d | 170 | table, |
group-onsemi | 0:098463de4c5d | 171 | column, |
group-onsemi | 0:098463de4c5d | 172 | self.escape_string(value)) |
group-onsemi | 0:098463de4c5d | 173 | rows = self.select_all(query) |
group-onsemi | 0:098463de4c5d | 174 | if len(rows) == 1: |
group-onsemi | 0:098463de4c5d | 175 | result = rows[0][table_pk] |
group-onsemi | 0:098463de4c5d | 176 | elif len(rows) == 0 and update_db: |
group-onsemi | 0:098463de4c5d | 177 | # Update DB with new value |
group-onsemi | 0:098463de4c5d | 178 | result = self.update_table_entry(table, column, value) |
group-onsemi | 0:098463de4c5d | 179 | return result |
group-onsemi | 0:098463de4c5d | 180 | |
group-onsemi | 0:098463de4c5d | 181 | def update_table_entry(self, table, column, value): |
group-onsemi | 0:098463de4c5d | 182 | """ Updates table entry if value in specified column doesn't exist |
group-onsemi | 0:098463de4c5d | 183 | Locks table to perform atomic read + update |
group-onsemi | 0:098463de4c5d | 184 | """ |
group-onsemi | 0:098463de4c5d | 185 | result = None |
group-onsemi | 0:098463de4c5d | 186 | con = self.db_object |
group-onsemi | 0:098463de4c5d | 187 | cur = con.cursor() |
group-onsemi | 0:098463de4c5d | 188 | cur.execute("LOCK TABLES `%s` WRITE"% table) |
group-onsemi | 0:098463de4c5d | 189 | table_pk = '%s_pk'% table |
group-onsemi | 0:098463de4c5d | 190 | query = """SELECT `%s` |
group-onsemi | 0:098463de4c5d | 191 | FROM `%s` |
group-onsemi | 0:098463de4c5d | 192 | WHERE `%s`='%s'"""% (table_pk, |
group-onsemi | 0:098463de4c5d | 193 | table, |
group-onsemi | 0:098463de4c5d | 194 | column, |
group-onsemi | 0:098463de4c5d | 195 | self.escape_string(value)) |
group-onsemi | 0:098463de4c5d | 196 | cur.execute(query) |
group-onsemi | 0:098463de4c5d | 197 | rows = cur.fetchall() |
group-onsemi | 0:098463de4c5d | 198 | if len(rows) == 0: |
group-onsemi | 0:098463de4c5d | 199 | query = """INSERT INTO `%s` (%s) |
group-onsemi | 0:098463de4c5d | 200 | VALUES ('%s')"""% (table, |
group-onsemi | 0:098463de4c5d | 201 | column, |
group-onsemi | 0:098463de4c5d | 202 | self.escape_string(value)) |
group-onsemi | 0:098463de4c5d | 203 | cur.execute(query) |
group-onsemi | 0:098463de4c5d | 204 | result = cur.lastrowid |
group-onsemi | 0:098463de4c5d | 205 | con.commit() |
group-onsemi | 0:098463de4c5d | 206 | cur.execute("UNLOCK TABLES") |
group-onsemi | 0:098463de4c5d | 207 | return result |
group-onsemi | 0:098463de4c5d | 208 | |
group-onsemi | 0:098463de4c5d | 209 | def update_build_id_info(self, build_id, **kw): |
group-onsemi | 0:098463de4c5d | 210 | """ Update additional data inside build_id table |
group-onsemi | 0:098463de4c5d | 211 | Examples: |
group-onsemi | 0:098463de4c5d | 212 | db.update_build_id_info(build_id, _status_fk=self.BUILD_ID_STATUS_COMPLETED, _shuffle_seed=0.0123456789): |
group-onsemi | 0:098463de4c5d | 213 | """ |
group-onsemi | 0:098463de4c5d | 214 | if len(kw): |
group-onsemi | 0:098463de4c5d | 215 | con = self.db_object |
group-onsemi | 0:098463de4c5d | 216 | cur = con.cursor() |
group-onsemi | 0:098463de4c5d | 217 | # Prepare UPDATE query |
group-onsemi | 0:098463de4c5d | 218 | # ["`mtest_build_id_pk`=[value-1]", "`mtest_build_id_name`=[value-2]", "`mtest_build_id_desc`=[value-3]"] |
group-onsemi | 0:098463de4c5d | 219 | set_list = [] |
group-onsemi | 0:098463de4c5d | 220 | for col_sufix in kw: |
group-onsemi | 0:098463de4c5d | 221 | assign_str = "`%s%s`='%s'"% (self.TABLE_BUILD_ID, col_sufix, self.escape_string(str(kw[col_sufix]))) |
group-onsemi | 0:098463de4c5d | 222 | set_list.append(assign_str) |
group-onsemi | 0:098463de4c5d | 223 | set_str = ', '.join(set_list) |
group-onsemi | 0:098463de4c5d | 224 | query = """UPDATE `%s` |
group-onsemi | 0:098463de4c5d | 225 | SET %s |
group-onsemi | 0:098463de4c5d | 226 | WHERE `mtest_build_id_pk`=%d"""% (self.TABLE_BUILD_ID, |
group-onsemi | 0:098463de4c5d | 227 | set_str, |
group-onsemi | 0:098463de4c5d | 228 | build_id) |
group-onsemi | 0:098463de4c5d | 229 | cur.execute(query) |
group-onsemi | 0:098463de4c5d | 230 | con.commit() |
group-onsemi | 0:098463de4c5d | 231 | |
group-onsemi | 0:098463de4c5d | 232 | def insert_test_entry(self, build_id, target, toolchain, test_type, test_id, test_result, test_output, test_time, test_timeout, test_loop, test_extra=''): |
group-onsemi | 0:098463de4c5d | 233 | """ Inserts test result entry to database. All checks regarding existing |
group-onsemi | 0:098463de4c5d | 234 | toolchain names in DB are performed. |
group-onsemi | 0:098463de4c5d | 235 | If some data is missing DB will be updated |
group-onsemi | 0:098463de4c5d | 236 | """ |
group-onsemi | 0:098463de4c5d | 237 | # Get all table FK and if entry is new try to insert new value |
group-onsemi | 0:098463de4c5d | 238 | target_fk = self.get_table_entry_pk(self.TABLE_TARGET, self.TABLE_TARGET + '_name', target) |
group-onsemi | 0:098463de4c5d | 239 | toolchain_fk = self.get_table_entry_pk(self.TABLE_TOOLCHAIN, self.TABLE_TOOLCHAIN + '_name', toolchain) |
group-onsemi | 0:098463de4c5d | 240 | test_type_fk = self.get_table_entry_pk(self.TABLE_TEST_TYPE, self.TABLE_TEST_TYPE + '_name', test_type) |
group-onsemi | 0:098463de4c5d | 241 | test_id_fk = self.get_table_entry_pk(self.TABLE_TEST_ID, self.TABLE_TEST_ID + '_name', test_id) |
group-onsemi | 0:098463de4c5d | 242 | test_result_fk = self.get_table_entry_pk(self.TABLE_TEST_RESULT, self.TABLE_TEST_RESULT + '_name', test_result) |
group-onsemi | 0:098463de4c5d | 243 | |
group-onsemi | 0:098463de4c5d | 244 | con = self.db_object |
group-onsemi | 0:098463de4c5d | 245 | cur = con.cursor() |
group-onsemi | 0:098463de4c5d | 246 | |
group-onsemi | 0:098463de4c5d | 247 | query = """ INSERT INTO `%s` (`mtest_build_id_fk`, |
group-onsemi | 0:098463de4c5d | 248 | `mtest_target_fk`, |
group-onsemi | 0:098463de4c5d | 249 | `mtest_toolchain_fk`, |
group-onsemi | 0:098463de4c5d | 250 | `mtest_test_type_fk`, |
group-onsemi | 0:098463de4c5d | 251 | `mtest_test_id_fk`, |
group-onsemi | 0:098463de4c5d | 252 | `mtest_test_result_fk`, |
group-onsemi | 0:098463de4c5d | 253 | `mtest_test_output`, |
group-onsemi | 0:098463de4c5d | 254 | `mtest_test_time`, |
group-onsemi | 0:098463de4c5d | 255 | `mtest_test_timeout`, |
group-onsemi | 0:098463de4c5d | 256 | `mtest_test_loop_no`, |
group-onsemi | 0:098463de4c5d | 257 | `mtest_test_result_extra`) |
group-onsemi | 0:098463de4c5d | 258 | VALUES (%d, %d, %d, %d, %d, %d, '%s', %.2f, %.2f, %d, '%s')"""% (self.TABLE_TEST_ENTRY, |
group-onsemi | 0:098463de4c5d | 259 | build_id, |
group-onsemi | 0:098463de4c5d | 260 | target_fk, |
group-onsemi | 0:098463de4c5d | 261 | toolchain_fk, |
group-onsemi | 0:098463de4c5d | 262 | test_type_fk, |
group-onsemi | 0:098463de4c5d | 263 | test_id_fk, |
group-onsemi | 0:098463de4c5d | 264 | test_result_fk, |
group-onsemi | 0:098463de4c5d | 265 | self.escape_string(test_output), |
group-onsemi | 0:098463de4c5d | 266 | test_time, |
group-onsemi | 0:098463de4c5d | 267 | test_timeout, |
group-onsemi | 0:098463de4c5d | 268 | test_loop, |
group-onsemi | 0:098463de4c5d | 269 | self.escape_string(test_extra)) |
group-onsemi | 0:098463de4c5d | 270 | cur.execute(query) |
group-onsemi | 0:098463de4c5d | 271 | con.commit() |