Untitled

import mariadb
import sys
import dbconfig
from datetime import datetime
import random
import time

try:
	conn = mariadb.connect(
		user=dbconfig.user,
		password=dbconfig.password,
		host=dbconfig.host,
		port=dbconfig.port,
		)
except mariadb.Error as e:
	print(f'Error connecting to MariaDB Platform: {e}')
	sys.exit(1)

cursor = conn.cursor()

try:
	# Database
	# cursor.execute('DROP DATABASE test_db')
	cursor.execute('CREATE DATABASE IF NOT EXISTS test_db')
	cursor.execute('USE test_db')
	
	# Tables
	# cursor.execute('DROP TABLE IF EXISTS test_table')
	cursor.execute(
		'CREATE TABLE IF NOT EXISTS sessions (id MEDIUMINT NOT NULL AUTO_INCREMENT, start_time DATETIME, PRIMARY KEY (id))')
	cursor.execute(
		'CREATE TABLE IF NOT EXISTS measurements (id MEDIUMINT NOT NULL AUTO_INCREMENT, session INT NOT NULL, measure_time DATETIME, sensor VARCHAR(16), value FLOAT, PRIMARY KEY (id))')
	
	# Session
	start_time = datetime.now()
	params = [
		(start_time),
	]
	cursor.execute('INSERT INTO sessions (start_time) VALUES (?)', params)
	session = cursor.lastrowid

	# Measurements
	for i in range(10):
		measure_time = datetime.now()
		params = [
			(session, measure_time, 'TMP36', random.random()*100),
			(session, measure_time, 'TMP37', random.random()*100),
			(session, measure_time, 'TMP38', random.random()*100),
		]
		cursor.executemany('INSERT INTO measurements (session, measure_time, sensor, value) VALUES (?, ?, ?, ?)', params)
		conn.commit()
		time.sleep(1)

except mariadb.Error as e:
	print(f'Error: {e}')