Experimental Physics and
Industrial Control System

def db_fetch1(variable, time1, time2):

    import pymysql

    import numpy as np

    conn = pymysql.connect(host='accmysqlslv', port=3306, user='archive', passwd='archive', db='archive2')

    cur = conn.cursor()

    command = "select float_val from sample s where s.channel_id = (select channel_id from channel where name = '" + variable + "') and smpl_time >= '" + time1 + "' and smpl_time < '"+ time2 + "'"

    cur.execute(command)

    output = []

    for row in cur:

        if np.isreal(row[0]) == True:

            output.append(row[0])

    cur.close()

    conn.close()

    output = np.array(output,dtype=float)

    return output