diff --git a/.gitignore b/.gitignore index 3680055..e1e226f 100644 --- a/.gitignore +++ b/.gitignore @@ -9,6 +9,7 @@ Code-C/main Code-C/exect Code-C/ctest Code-C/DartConfiguration.tcl +Code-C/tsl Makefile diff --git a/Code-C/Include/TSL2561.h b/Code-C/Include/TSL2561.h new file mode 100644 index 0000000..9cccbd3 --- /dev/null +++ b/Code-C/Include/TSL2561.h @@ -0,0 +1,14 @@ +#include +#include +#include +#include +#include +#include + + +char *bus = "/dev/i2c-1"; + +void printSpectrum(int file); +float getFullSpectrum(int file); +float getInfraredLight(int file); +int init_TSL2561(char *bus); diff --git a/Code-C/include/average.h b/Code-C/Include/average.h similarity index 100% rename from Code-C/include/average.h rename to Code-C/Include/average.h diff --git a/Code-C/include/b2hd.h b/Code-C/Include/b2hd.h similarity index 100% rename from Code-C/include/b2hd.h rename to Code-C/Include/b2hd.h diff --git a/Code-C/include/fileGestion.h b/Code-C/Include/fileGestion.h similarity index 100% rename from Code-C/include/fileGestion.h rename to Code-C/Include/fileGestion.h diff --git a/Code-C/include/getArray.h b/Code-C/Include/getArray.h similarity index 100% rename from Code-C/include/getArray.h rename to Code-C/Include/getArray.h diff --git a/Code-C/include/growthRate.h b/Code-C/Include/growthRate.h similarity index 100% rename from Code-C/include/growthRate.h rename to Code-C/Include/growthRate.h diff --git a/Code-C/include/initialParameters.h b/Code-C/Include/initialParameters.h similarity index 100% rename from Code-C/include/initialParameters.h rename to Code-C/Include/initialParameters.h diff --git a/Code-C/include/power.h b/Code-C/Include/power.h similarity index 100% rename from Code-C/include/power.h rename to Code-C/Include/power.h diff --git a/Code-C/include/queue.h b/Code-C/Include/queue.h similarity index 100% rename from Code-C/include/queue.h rename to Code-C/Include/queue.h diff --git a/Code-C/include/simulateFlux.h b/Code-C/Include/simulateFlux.h similarity index 100% rename from Code-C/include/simulateFlux.h rename to Code-C/Include/simulateFlux.h diff --git a/Code-C/TSL2561.c b/Code-C/TSL2561.c new file mode 100644 index 0000000..152fa5d --- /dev/null +++ b/Code-C/TSL2561.c @@ -0,0 +1,107 @@ +// Code from the following github repo: https://github.com/ControlEverythingCommunity/TSL2561/blob/master/C/TSL2561.c +#include "include/TSL2561.h" + +void printSpectrum(int file) +{ + // Read 4 bytes of data from register(0x0C | 0x80) + // ch0 lsb, ch0 msb, ch1 lsb, ch1 msb + char reg[1] = {0x0C | 0x80}; + write(file, reg, 1); + char data[4] = {0}; + if(read(file, data, 4) != 4) + { + printf("Erorr : Input/output Erorr \n"); + } + else + { + // Convert the data + float ch0 = (data[1] * 256 + data[0]); //Full Spectrum(IR + Visible) + float ch1 = (data[3] * 256 + data[2]); //Infrared Value + // Output data to screen + printf("Full Spectrum(IR + Visible) : %.1f lux \n", ch0); + printf("Infrared Value : %.1f lux \n", ch1); + printf("Visible Value : %.1f lux \n", (ch0 - ch1)); + } +} + +float getFullSpectrum(int file) +{ + // Read 4 bytes of data from register(0x0C | 0x80) + // ch0 lsb, ch0 msb, ch1 lsb, ch1 msb + char reg[1] = {0x0C | 0x80}; + write(file, reg, 1); + char data[4] = {0}; + if(read(file, data, 4) != 4) + { + printf("Erorr : Input/output Erorr \n"); + } + else + { + // Convert the data + float ch0 = (data[1] * 256 + data[0]); //Full Spectrum(IR + Visible) + return ch0; + } +} + +float getInfraredLight(int file) +{ + // Read 4 bytes of data from register(0x0C | 0x80) + // ch0 lsb, ch0 msb, ch1 lsb, ch1 msb + char reg[1] = {0x0C | 0x80}; + write(file, reg, 1); + char data[4] = {0}; + if(read(file, data, 4) != 4) + { + printf("Erorr : Input/output Erorr \n"); + } + else + { + // Convert the data + float ch1 = (data[3] * 256 + data[2]); //Infrared Value + return ch1; + } +} + +int init_TSL2561(char *bus) +{ + int file; + if((file = open(bus, O_RDWR)) < 0) + { + printf("Failed to open the bus. \n"); + exit(1); + } + // Get I2C device, TSL2561 I2C address is 0x39(57) + ioctl(file, I2C_SLAVE, 0x39); + + // Select control register(0x00 | 0x80) + // Power ON mode(0x03) + char config[2] = {0}; + config[0] = 0x00 | 0x80; + config[1] = 0x03; + write(file, config, 2); + // Select timing register(0x01 | 0x80) + // Nominal integration time = 402ms(0x02) + config[0] = 0x01 | 0x80; + config[1] = 0x02; + write(file, config, 2); + return file; +} + +void TSL2561() +{ + int fe = 1; + int file; + file = init_TSL2561(bus); + while(1) + { + sleep(1/fe); + float a = getFullSpectrum(file); + float b = getInfraredLight(file); + printf("%.1f\n",a); + printf("%.1f\n",b); + printSpectrum(file); + } +} +void main(){ + TSL2561(); +} \ No newline at end of file diff --git a/Code-C/getArray.c b/Code-C/getArray.c index 3b775d4..903c4f5 100644 --- a/Code-C/getArray.c +++ b/Code-C/getArray.c @@ -1,7 +1,7 @@ #include "include/getArray.h" #include "include/fileGestion.h" #include "include/initialParameters.h" -//#include +// #include long **getlongArray(int N, int M) /* Allocate the array */ { @@ -27,11 +27,11 @@ double **getDoubleArray(int N, int M) /* Allocate the array */ void fillArrayWithRawData(char *rawDataFileName, long **p, int N, int M) { - int i = 0, j; - char *buffer; - size_t bufsize = 200; - buffer = (char *)malloc(bufsize * sizeof(char)); - char *token; + int i = 0; + // char *buffer; + // size_t bufsize = 200; + // buffer = (char *)malloc(bufsize * sizeof(char)); + // char *token; FILE *f = fopen(rawDataFileName, "r"); diff --git a/Code-C/getArray.h b/Code-C/getArray.h deleted file mode 100644 index 6d75887..0000000 --- a/Code-C/getArray.h +++ /dev/null @@ -1,11 +0,0 @@ -#include -#include -#include -#include -#include -#include - -long **getRawDataArray(char *rawDataFileName, int N , int M); -void printArrayData(long** p, int N, int M); -void freeArray(long **p, int N); -bool checkArrayFullyFill(long **p, int N ); \ No newline at end of file diff --git a/Db-Script/DatabaseScript.ipynb b/Db-Script/DatabaseScript.ipynb new file mode 100644 index 0000000..68bf25b --- /dev/null +++ b/Db-Script/DatabaseScript.ipynb @@ -0,0 +1,931 @@ +{ + "cells": [ + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

Forecast Project

" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

Database

" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "Import packages for DB" + ] + }, + { + "cell_type": "code", + "execution_count": 1, + "metadata": {}, + "outputs": [], + "source": [ + "import yfinance as yfin\n", + "import sqlite3 as sql\n", + "import pandas as pd\n", + "import os\n", + "import datetime\n", + "import matplotlib.pyplot as plt\n", + "import numpy as np" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

YFianance API

\n", + "

Function using the yfinance API to get all market data

" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "Tickers" + ] + }, + { + "cell_type": "code", + "execution_count": 2, + "metadata": {}, + "outputs": [], + "source": [ + "#array with all the studied currencies (yahoo finance currency names)\n", + "currencies = [\"BTC-USD\",\"ETH-USD\",\"TTE.PA\"] " + ] + }, + { + "cell_type": "code", + "execution_count": 3, + "metadata": {}, + "outputs": [], + "source": [ + "def getMetaData(s : str) -> dict :\n", + " \"\"\"Get the meta information for a Ticker (currency)\n", + " \n", + " Args : \n", + " s (str) : name of the Ticker\n", + " \n", + " Return : \n", + " dict : return all the meta information of the Ticker, the dict is the following : \n", + " - symbol : str ~> name online (yahoo finance) of the stock (is also the ticker name used by the yfinance API)\n", + " - instrumentType : str ~> type of stock, can be a cryptocurrency , a stock ...\n", + " - regularMarketTime int : ~> date when those informatation has been gathered in epoch/unix time \n", + " - gmtoffset int : ~> number of second of offset between the stock's market timezome and the gtm timzome\n", + " - timezone str : ~> name of the stock's market timezone\n", + " other var a disponnible but not used here (see yfinance documentation)\n", + " \"\"\" \n", + " ticker = yfin.Ticker(s)\n", + " ticker.history()\n", + " meta = ticker.history_metadata\n", + " return meta\n", + " \n", + "def getHistoryData(s : str) -> dict :\n", + " \"\"\"Get all the information since the creation of the Ticker (currency)\n", + " \n", + " Args : \n", + " s (str) : name of the Ticker\n", + " \n", + " Return : \n", + " dict : return all the information of the Ticker since creation, the dict contaign the following information : {Date,Open,Hight,Low,Close,Volume}\n", + " \"\"\"\n", + " ticker = yfin.Ticker(s)\n", + " data = ticker.history(\"max\", interval = '1d')\n", + " data['Date'] = data.index\n", + " data = data[[\"Date\", \"Open\", \"High\", \"Low\", \"Close\", \"Volume\"]]\n", + " data.reset_index(drop=True, inplace=True)\n", + " return data\n", + "\n", + "def getPeriodData(s : str , period : str) -> dict :\n", + " \"\"\"Get the information of the Ticker for a certain period\n", + " \n", + " Args : \n", + " s (str) : name of the Ticker\n", + " period (str) : duration of the period , the information period get are ending to the current day and start a period back can take value like {1d , 5d , 1m , 1y , ...}\n", + " \n", + " Return : \n", + " dict : return all the information of the Ticker for the period, the dict contaign the following information : {Date,Open,Hight,Low,Close,Volume}\n", + " \"\"\"\n", + " ticker = yfin.Ticker(s)\n", + " data = ticker.history(period = period ,interval = '1d')\n", + " data['Date'] = data.index\n", + " data = data[[\"Date\", \"Open\", \"High\",\"Low\", \"Close\", \"Volume\"]]\n", + " data.reset_index(drop=True, inplace=True)\n", + " return data" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

DataBase Gestion

" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

Currencies_Metadata table

\n", + "

This table contaign all the usefull metadata of each currencies fetched. It contaigns :

\n", + "
  • currencyName ~> name online (yahoo finance) of the stock (is also the ticker name used by the yfinance API)
    • \n", + "
  • instrumentType ~> type of stock, can be a cryptocurrency , a stock ...
    • \n", + "
  • regularMarketTime ~> date when those informatation has been gathered in epoch/unix time
    • \n", + "
  • gtmOffset ~> number of second of offset between the stock's market timezome and the gtm timezome
    • \n", + "
  • timezone ~> name of the stock's market timezone
\n", + "It is possible to \n", + "
  • Create / Fill table
    • \n", + "
  • Insert / Get / Modify / Delete / Print table elements
" + ] + }, + { + "cell_type": "code", + "execution_count": 25, + "metadata": {}, + "outputs": [], + "source": [ + "def createCurrencyMetadataTable():\n", + " \"\"\"Create a new currency table \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + "\n", + " requestCreate = '''CREATE TABLE IF NOT EXISTS CURRENCIES_METADATA (\n", + " [currencyId] INTEGER PRIMARY KEY,\n", + " [currencyName] TEXT, \n", + " [instrumentType] TEXT,\n", + " [regularMarketTime] TEXT,\n", + " [gtmOffset] INTEGER,\n", + " [timezone] TEXT\n", + " )'''\n", + " #currencyName : str ~> name online (yahoo finance) of the stock (is also the ticker name used by the yfinance API)\n", + " #instrumentType : str ~> type of stock, can be a cryptocurrency , a stock ...\n", + " #regularMarketTime int : ~> date when those informatation has been gathered in epoch/unix time \n", + " #gtmOffset int : ~> number of second of offset between the stock's market timezome and the gtm timzome\n", + " #timezone str : ~> name of the stock's market timezone\n", + " c.execute(requestCreate) # create a new currency table\n", + " db.commit()\n", + "\n", + "def getCurrencyMetadataElement(currencyId : int) -> dict :\n", + " \"\"\"Get an element of the currency table by its id\n", + "\n", + " Args:\n", + " currencyId (int): id of the currency in the table\n", + "\n", + " Returns:\n", + " dict: return the element as a dict with all metadata of a currency\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " request = f'''SELECT * FROM CURRENCIES_METADATA WHERE currencyId='{currencyId}' '''\n", + " c.execute(request)\n", + " return list(c.fetchone())\n", + "\n", + "def getIdByNameCurrencyMetadata(currencyName: str) -> int :\n", + " \"\"\"Get an element id of the currency table by its name\n", + "\n", + " Args:\n", + " currencyName (str): name of the stock\n", + "\n", + " Returns:\n", + " int: return the element id\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " request = f'''SELECT currencyId FROM CURRENCIES_METADATA WHERE currencyName='{currencyName}' '''\n", + " c.execute(request)\n", + " return c.fetchone()[0]\n", + "\n", + "def printCurrencyMetadataElement(currencyId : int):\n", + " \"\"\"Print an element of the currency table by its id \n", + "\n", + " Args:\n", + " currencyId (int): id of the currency in the table \n", + " \"\"\"\n", + " metaData = getCurrencyMetadataElement(currencyId)\n", + " header = f\"-------- MetaData for {metaData[1]} --------\"\n", + " nHeader = len(header)\n", + " print(header)\n", + " print(f\"\\nName : {metaData[1]}\")\n", + " print(f\"ID : {metaData[0]}\")\n", + " print(f\"instrumentType : {metaData[2]}\")\n", + " print(f\"regularMarketTime : {metaData[3]}\")\n", + " print(f\"gtmOffset : {metaData[4]}\")\n", + " print(f\"timezone : {metaData[5]}\")\n", + " footer = \"\\n\"\n", + " for i in range(nHeader): footer += \"-\"\n", + " print(footer)\n", + "\n", + "def insertCurrencyMetadataElement(currency : str):\n", + " \"\"\"Insert a new element in the currency table\n", + "\n", + " Args:\n", + " currency (str): name of the currency to fetch its metadata with the yFinance API\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " metaData = getMetaData(currency)\n", + " request = f'''INSERT INTO CURRENCIES_METADATA (currencyName,instrumentType,regularMarketTime,gtmOffset,timezone)\n", + " VALUES (\n", + " '{metaData['symbol']}',\n", + " '{metaData['instrumentType']}',\n", + " '{metaData['regularMarketTime']}',\n", + " {metaData['gmtoffset']},\n", + " '{metaData['timezone']}')'''\n", + " c.execute(request)\n", + " db.commit()\n", + "\n", + "def modifyCurrencyMetadataElement(currencyId : int, newMetaData : dict):\n", + " \"\"\"Modify an element in the currency table, the element to modify must be enteriely rewrite \n", + "\n", + " Args:\n", + " currencyId (int): id of the currency to modify in the currency table\n", + " newMetaData (dict): dictionnary contaigning all the information of the currency even the ones not changed\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " #All the information MUST be given in the newMetaData dict even the id and the ones not changed\n", + " request = f'''UPDATE CURRENCIES_METADATA \n", + " SET \n", + " currencyId={newMetaData['currencyId']},\n", + " currencyName='{newMetaData['symbol']}', \n", + " instrumentType='{newMetaData['instrumentType']}', \n", + " regularMarketTime='{newMetaData['regularMarketTime']}',\n", + " gtmOffset={newMetaData['gtmOffset']},\n", + " timezone='{newMetaData['timezone']}' \n", + " WHERE currencyId = {currencyId}'''\n", + " c.execute(request)\n", + " db.commit()\n", + "\n", + "def deleteCurrencyMetadataElement(currencyId : int):\n", + " \"\"\"Delete an element from the currency table\n", + "\n", + " Args:\n", + " currencyId (int): id of the currency to delete from the currency table\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " request = f'''DELETE FROM CURRENCIES_METADATA\n", + " WHERE currencyId = {currencyId}'''\n", + " c.execute(request)\n", + " db.commit()\n" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

Others

\n", + "

Usefull an necessary function for next parts

" + ] + }, + { + "cell_type": "code", + "execution_count": 5, + "metadata": {}, + "outputs": [], + "source": [ + "def cleanNameForSQL(s : str) -> str:\n", + "\t\"\"\"Return a new string that dont contaign special char to use it as sql table name\n", + "\n", + "\tArgs:\n", + "\t\ts (str): string where to remove special char \n", + "\n", + "\tReturns:\n", + "\t\tstr: new string without special char nor spaces \n", + "\t\"\"\"\n", + "\tfor char in ['-','.','^',' ']:\n", + "\t\ts = s.replace(char,\"\")\n", + "\treturn s" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

Market Tables

\n", + "There is one market table for each currency fetched. It contaigns :\n", + "
  • Date ~> date of the information present
    • \n", + "
  • Open ~> value of the stock when the market open
    • \n", + "
  • High ~> highest value reach by the stock during the market time
    • \n", + "
  • Low ~> lowest value reach by the stock during the market time
    • \n", + "
  • Close ~> value of the stock when the market close
    • \n", + "
  • Volume ~> total of stock sells during the market time
    • \n", + "
\n", + "It is possible to \n", + "
  • Create / Fill table
    • \n", + "
  • Insert / Get / Print table elements
" + ] + }, + { + "cell_type": "code", + "execution_count": 6, + "metadata": {}, + "outputs": [], + "source": [ + "def createCurrencyMarketTable(currencyName : str):\n", + " \"\"\"Create a new table if it dont alredy exist to contaign all the market infomation of a currency\n", + "\n", + " Args:\n", + " currencyName (str): name of the currency for which a new table is created\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " tableName = cleanNameForSQL(currencyName)\n", + " #each lign in the table represent a new day and contaign :\n", + " # Date : date ~> date of the information present\n", + " # Open : float ~> value of the stock when the market open\n", + " # High : float ~> highest value reach by the stock during the market time \n", + " # Low : float ~> lowest value reach by the stock during the market time\n", + " # Close : float ~> value of the stock when the market close \n", + " # Volume : float ~> total of stock sells during the market time \n", + " createNewCurrencyTable = f'''CREATE TABLE IF NOT EXISTS {tableName}_MARKET \n", + " ([Id] INTEGER PRIMARY KEY AUTOINCREMENT,\n", + " [Date] TEXT,\n", + " [Open] NUMBER,\n", + " [High] NUMBER,\n", + " [Low] NUMBER,\n", + " [Close] NUMBER,\n", + " [Volume] INTEGER);'''\n", + " c.execute(createNewCurrencyTable)\n", + " db.commit()\n", + "\n", + "def fillCurrencyMarketTable(currency : str , period : str = None):\n", + " \"\"\"Fill a currency market table with its information\n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency , used to get the information with the API\n", + " period (str, optional): default value is none : all the information since create are fetched, can be defined to limit the period (for value value autorized see yfinance doc). Defaults to None.\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + "\n", + " tableName = cleanNameForSQL(currency)\n", + " requestTemplate = f'''INSERT INTO {tableName}_MARKET (Date,Open,High,Low,Close,Volume)\n", + " VALUES '''\n", + "\n", + " #verify if @period has been enter as parameter\n", + " if period : data = getPeriodData(currency , period) #if yes get only period data\n", + " else : data = getHistoryData(currency) # else get all data since creation\n", + "\n", + " #for each lign in data fetched, the request add them in the table\n", + " for i in range(len(data)):\n", + " line = data.iloc[i]\n", + " #round(line[2:5],13) #all number are rounded to the 13th decimal to avoid some float type python issues \n", + " request =requestTemplate + f'''('{line['Date']}',\n", + " {line['Open']},\n", + " {line['High']},\n", + " {line['Low']},\n", + " {line['Close']},\n", + " {line['Volume']});'''\n", + "\n", + " c.execute(request)\n", + " db.commit()\n", + "\n", + "def getCurrencyMarketElementById(currency : str , elementId : int ) -> dict :\n", + " \"\"\"Get an element from a currency market table by its id \n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency , used to get the information with the API\n", + " elementId (int): id of the element to get \n", + "\n", + " Returns:\n", + " dict: element of the table which id is elementId \n", + " \"\"\"\n", + " tableName = cleanNameForSQL(currency)\n", + " request = f'''SELECT * FROM {tableName}_MARKET WHERE Id = {elementId} '''\n", + "\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " c.execute(request)\n", + " return c.fetchone()[0]\n", + "\n", + "def getAllCurrencyMarketElement(currency : str ) -> pd.DataFrame :\n", + " \"\"\"Get all elements from a currency market table by its id \n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency , used to get the information with the API\n", + "\n", + " Returns:\n", + " list: list of all elements of the table \n", + " \"\"\"\n", + " tableName = cleanNameForSQL(currency)\n", + " request = f'''SELECT Date,Open,High,Low,Close,Volume FROM {tableName}_MARKET'''\n", + "\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " c.execute(request)\n", + " res = pd.DataFrame(c.fetchall(),columns=['Date','Open','High','Low','Close','Volume'])\n", + " # for i in range(len(res)):\n", + " # res[i] = list(res[i])\n", + " return res\n", + "\n", + "def getCloseCurrencyMarketElement(currency : str ) -> list :\n", + " \"\"\"Get close elements from a currency market table by its id \n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency , used to get the information with the API\n", + "\n", + " Returns:\n", + " list: list of all elements of the table \n", + " \"\"\"\n", + " tableName = cleanNameForSQL(currency)\n", + " request = f'''SELECT Close FROM {tableName}_MARKET'''\n", + "\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " c.execute(request)\n", + " res = c.fetchall()\n", + " for i in range(len(res)):\n", + " res[i] = list(res[i])[0]\n", + " return res\n", + "\n", + "def getDateCurrencyMarketElement(currency : str ) -> list :\n", + " \"\"\"Get date elements from a currency market table by its id \n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency , used to get the information with the API\n", + "\n", + " Returns:\n", + " list: list of all elements of the table \n", + " \"\"\"\n", + " tableName = cleanNameForSQL(currency)\n", + " request = f'''SELECT Date FROM {tableName}_MARKET'''\n", + "\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " c.execute(request)\n", + " res = c.fetchall()\n", + " for i in range(len(res)):\n", + " res[i] = datetime.datetime.strptime(list(res[i])[0][2:10],\"%y-%m-%d\").date()\n", + " return res\n", + "\n", + "def insertCurrencyMarketElement(currency : str, element : dict):\n", + " \"\"\"Insert a new currency market element in the corresponding table\n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency\n", + " element (dict): new element to add in the table , this dict must contaign definition for {Date,Open,Hight,Low,Close,Volume}\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " tableName = cleanNameForSQL(currency)\n", + " request = f'''INSERT INTO {tableName}_MARKET (Date,Open,High,Low,Close,Volume) VALUES \n", + " ('{element['Date']}',{element['Open']},{element['High']},{element['Low']},{element['Close']},{element['Volume']})'''\n", + " c .execute(request)\n", + " db.commit()\n", + "\n", + "def printCurrencyMarketElement(currency : str , currencyId : int):\n", + " \"\"\"Print an element of the currency table by its id \n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency \n", + " currencyId (int): id of the currency in the table \n", + " \"\"\"\n", + " data = getCurrencyMarketElementById(currency , currencyId)\n", + " header = f\"-------- Value for {currency} ID°{currencyId} --------\\n\"\n", + " nHeader = len(header)\n", + " print(header)\n", + " print(f\"Date : {data[1]}\")\n", + " print(f\"Open : {data[2]}\")\n", + " print(f\"High : {data[3]}\")\n", + " print(f\"Low : {data[4]}\")\n", + " print(f\"Close : {data[5]}\")\n", + " print(f\"Volume : {data[6]}\")\n", + " footer = \"\\n\"\n", + " for i in range(nHeader): footer += \"-\"\n", + " print(footer)\n", + "\n", + "#No Modify or Delete function debause they currently don't seem usefull " + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

Forecast Table

\n", + "There is one forcast table for each currency fetched. It contaigns :\n", + "
  • Date ~> date of the forecast
    • \n", + "
  • Open ~> forecast value of the stock when the market open
    • \n", + "
  • High ~> forecast highest value reach by the stock during the market time
    • \n", + "
  • Low ~> forecast lowest value reach by the stock during the market time
    • \n", + "
  • Close ~> forecast value of the stock when the market close
    • \n", + "
\n", + "It is possible to :\n", + "
  • Create / Fill table
    • \n", + "
  • Insert / Get / Modify / Delete / Print table elements
" + ] + }, + { + "cell_type": "code", + "execution_count": 7, + "metadata": {}, + "outputs": [], + "source": [ + "def createCurrencyForecastTable(currencyName : str):\n", + " \"\"\"Create a new table if it dont alredy exist to contaign market forecast prevision of a currency\n", + "\n", + " Args:\n", + " currencyName (str): name of the currency for which a new table is created \n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " tableName = cleanNameForSQL(currencyName)\n", + " #each lign in the table represent a new day and contaign :\n", + " # Date : date ~> forecast date of the information present\n", + " # Open : float ~> forecast value of the stock when the market open\n", + " # High : float ~> forecast highest value reach by the stock during the market time \n", + " # Low : float ~> forecast lowest value reach by the stock during the market time\n", + " # Close : float ~> forecast value of the stock when the market close \n", + " createNewCurrencyForecastTable = f'''CREATE TABLE IF NOT EXISTS {tableName}_FORECAST \n", + " ([Id] INTEGER PRIMARY KEY AUTOINCREMENT,\n", + " [Date] TEXT,\n", + " [Open] NUMBER,\n", + " [High] NUMBER,\n", + " [Low] NUMBER,\n", + " [Close] NUMBER)'''\n", + " c.execute(createNewCurrencyForecastTable)\n", + " db.commit()\n", + "\n", + "def getCurrencyForecastElementById(currency : str , elementId : int ) -> dict :\n", + " \"\"\"Get an from a currency forecast table by its id \n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency , used to get the information with the API\n", + " elementId (int): id of the element to get \n", + "\n", + " Returns:\n", + " dict: element of the table which id is elementId \n", + " \"\"\"\n", + " tableName = cleanNameForSQL(currency)\n", + " request = f'''SELECT * FROM {tableName}_FORECAST WHERE Id = {elementId} '''\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " c.execute(request)\n", + " return c.fetchone()[0]\n", + "\n", + "def insertCurrencyForecastElement(currency : str, element : dict):\n", + " \"\"\"Insert a new currency forecast element in the corresponding table \n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency\n", + " element (dict): new element to add in the table , this dict must contaign definition for {Date,Open,Hight,Low,Close,Volume}\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " tableName = cleanNameForSQL(currency)\n", + " request = f'''INSERT INTO {tableName}_FORECAST (Date,Open,High,Low,Close,Volume) VALUES \n", + " ('{element['Date']}',{element['Open']},{element['High']},{element['Low']},{element['Close']})'''\n", + " c .execute(request)\n", + " db.commit()\n", + "\n", + "def modifyCurrencyForecastElement(currency : str , elementId : int, newElement : dict):\n", + " \"\"\"Modify an element in the currency forecast table, the element to modify must be enteriely rewrite\n", + "\n", + " Args:\n", + " currency (str): id of the currency to modify in the currency table\n", + " elementId (int): id of the currency to modify in the currency table\n", + " newElement (dict): dictionnary contaigning all the information of the currency even the ones not changed\n", + " \"\"\"\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " #All the information MUST be given in the newMetaData dict even the id and the ones not changed\n", + " tableName = cleanNameForSQL(currency)\n", + " request = f'''UPDATE {tableName}_FORECAST \n", + " SET \n", + " Date={newElement['Id']},\n", + " Open='{newElement['Open']}', \n", + " High='{newElement['High']}', \n", + " Low={newElement['Low']},\n", + " Close={newElement['Close']},\n", + " WHERE Id = {elementId}'''\n", + " c.execute(request)\n", + " db.commit()\n", + "\n", + "def deleteCurrencyForecastElement(currency : str , currencyId : int):\n", + " \"\"\"Delete an element from the currency forecast table\n", + "\n", + " Args:\n", + " currency (str): yfinance currency name \n", + " currencyId (int): id of the currency to delete from the currency table\n", + " \"\"\"\n", + " tableName = cleanNameForSQL(currency)\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " request = f'''DELETE FROM {tableName}_FORECAST \n", + " WHERE currencyId = {currencyId}'''\n", + " c.execute(request)\n", + " db.commit()\n", + "\n", + "def printCurrencyForecastElement(currency : str , currencyId : int):\n", + " \"\"\"Print an element of the currency forecast table by its id \n", + "\n", + " Args:\n", + " currency (str): yahoo finance name of the currency \n", + " currencyId (int): id of the currency in the table \n", + " \"\"\"\n", + " data = getCurrencyForecastElementById(currency , currencyId)\n", + " header = f\"-------- Forecast for {currency} ID°{currencyId} --------\\n\"\n", + " nHeader = len(header)\n", + " print(header)\n", + " print(f\"Date : {data[1]}\")\n", + " print(f\"Open : {data[2]}\")\n", + " print(f\"High : {data[3]}\")\n", + " print(f\"Low : {data[4]}\")\n", + " print(f\"Close : {data[5]}\")\n", + " footer = \"\\n\"\n", + " for i in range(nHeader): footer += \"-\"\n", + " print(footer)\n" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

Initialization DB Function

\n", + "

Scipt to initialize the database

" + ] + }, + { + "cell_type": "code", + "execution_count": 26, + "metadata": {}, + "outputs": [], + "source": [ + "def setDb(currencies : list):\n", + " \"\"\"Initialize the database\n", + "\n", + " Args:\n", + " currencies (list): list of currencies to add during the db initailization\n", + " \"\"\"\n", + " createCurrencyMetadataTable()\n", + " for currency in currencies:\n", + " print(currency)\n", + " insertCurrencyMetadataElement(currency)\n", + " createCurrencyMarketTable(currency)\n", + " fillCurrencyMarketTable(currency,period = \"1y\")\n", + " createCurrencyForecastTable(currency)" + ] + }, + { + "cell_type": "code", + "execution_count": 27, + "metadata": {}, + "outputs": [ + { + "name": "stdout", + "output_type": "stream", + "text": [ + "BTC-USD\n", + "INSERT INTO CURRENCIES_METADATA (currencyName,instrumentType,regularMarketTime,gtmOffset,timezone)\n", + " VALUES (\n", + " 'BTC-USD',\n", + " 'CRYPTOCURRENCY',\n", + " '2023-04-25 11:45:00+00:00',\n", + " 0,\n", + " 'UTC')\n", + "ETH-USD\n", + "INSERT INTO CURRENCIES_METADATA (currencyName,instrumentType,regularMarketTime,gtmOffset,timezone)\n", + " VALUES (\n", + " 'ETH-USD',\n", + " 'CRYPTOCURRENCY',\n", + " '2023-04-25 11:45:00+00:00',\n", + " 0,\n", + " 'UTC')\n", + "TTE.PA\n", + "INSERT INTO CURRENCIES_METADATA (currencyName,instrumentType,regularMarketTime,gtmOffset,timezone)\n", + " VALUES (\n", + " 'TTE.PA',\n", + " 'EQUITY',\n", + " '2023-04-25 13:32:36+02:00',\n", + " 7200,\n", + " 'CEST')\n" + ] + } + ], + "source": [ + "#create db\n", + "try:\n", + " os.remove(\"mydatabase.db\") #delete database if it exixts \n", + "except:\n", + " pass # if it not exists just go next\n", + "setDb(currencies)" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

Display stock chart

" + ] + }, + { + "cell_type": "code", + "execution_count": 14, + "metadata": { + "tags": [] + }, + "outputs": [ + { + "ename": "OperationalError", + "evalue": "no such table: BTCUSD_MARKET", + "output_type": "error", + "traceback": [ + "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m", + "\u001b[0;31mOperationalError\u001b[0m Traceback (most recent call last)", + "Cell \u001b[0;32mIn[14], line 14\u001b[0m\n\u001b[1;32m 11\u001b[0m plt\u001b[39m.\u001b[39mplot(dateData,closeData)\n\u001b[1;32m 13\u001b[0m \u001b[39m# displayStockChart(\"BTC-USD\",\"5y\")\u001b[39;00m\n\u001b[0;32m---> 14\u001b[0m displaySimplerStockChart(\u001b[39m\"\u001b[39;49m\u001b[39mBTC-USD\u001b[39;49m\u001b[39m\"\u001b[39;49m)\n", + "Cell \u001b[0;32mIn[14], line 5\u001b[0m, in \u001b[0;36mdisplaySimplerStockChart\u001b[0;34m(currency)\u001b[0m\n\u001b[1;32m 3\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39mdisplaySimplerStockChart\u001b[39m(currency: \u001b[39mstr\u001b[39m):\n\u001b[1;32m 4\u001b[0m plt\u001b[39m.\u001b[39mstyle\u001b[39m.\u001b[39muse(\u001b[39m\"\u001b[39m\u001b[39mbmh\u001b[39m\u001b[39m\"\u001b[39m)\n\u001b[0;32m----> 5\u001b[0m closeData \u001b[39m=\u001b[39m getCloseCurrencyMarketElement(currency)\n\u001b[1;32m 6\u001b[0m dateData \u001b[39m=\u001b[39m getDateCurrencyMarketElement(currency)\n\u001b[1;32m 7\u001b[0m plt\u001b[39m.\u001b[39mfigure(figsize\u001b[39m=\u001b[39m(\u001b[39m16\u001b[39m,\u001b[39m4\u001b[39m))\n", + "Cell \u001b[0;32mIn[6], line 112\u001b[0m, in \u001b[0;36mgetCloseCurrencyMarketElement\u001b[0;34m(currency)\u001b[0m\n\u001b[1;32m 110\u001b[0m db \u001b[39m=\u001b[39m sql\u001b[39m.\u001b[39mconnect(\u001b[39m\"\u001b[39m\u001b[39mmydatabase.db\u001b[39m\u001b[39m\"\u001b[39m)\n\u001b[1;32m 111\u001b[0m c \u001b[39m=\u001b[39m db\u001b[39m.\u001b[39mcursor()\n\u001b[0;32m--> 112\u001b[0m c\u001b[39m.\u001b[39;49mexecute(request)\n\u001b[1;32m 113\u001b[0m res \u001b[39m=\u001b[39m c\u001b[39m.\u001b[39mfetchall()\n\u001b[1;32m 114\u001b[0m \u001b[39mfor\u001b[39;00m i \u001b[39min\u001b[39;00m \u001b[39mrange\u001b[39m(\u001b[39mlen\u001b[39m(res)):\n", + "\u001b[0;31mOperationalError\u001b[0m: no such table: BTCUSD_MARKET" + ] + } + ], + "source": [ + "import matplotlib.pyplot as plt \n", + "\n", + "def displaySimplerStockChart(currency: str):\n", + " plt.style.use(\"bmh\")\n", + " closeData = getCloseCurrencyMarketElement(currency)\n", + " dateData = getDateCurrencyMarketElement(currency)\n", + " plt.figure(figsize=(16,4))\n", + " plt.title(f\"{currency} Closing Prices\")\n", + " plt.xlabel('Date')\n", + " plt.ylabel('Closing Price')\n", + " plt.plot(dateData,closeData)\n", + "\n", + "# displayStockChart(\"BTC-USD\",\"5y\")\n", + "displaySimplerStockChart(\"BTC-USD\")" + ] + }, + { + "attachments": {}, + "cell_type": "markdown", + "metadata": {}, + "source": [ + "

Database Test

" + ] + }, + { + "cell_type": "code", + "execution_count": 13, + "metadata": {}, + "outputs": [], + "source": [ + "def GeneralDatabaseTest():\n", + " #Test if db exists\n", + " print(\"--- Database General Test ---\")\n", + " if os.path.exists(\"./mydatabase.db\") : \n", + " print(\"Test 1 passed : Database exist\")\n", + " else : \n", + " print(\"Test failled : No database named `mydatabase.db` created\")\n", + " return 0\n", + " return 1\n", + "\n", + "def CurrenciesMetadatGeneralTest():\n", + " \"\"\"Assert the structure of the CURRENCIES_METADATA is good\"\"\"\n", + " print(\"\\n--- CURRENCIES_METADATA General Test ---\")\n", + " #Test if CURRENCIES_METADATA structure is good\n", + " db = sql.connect(\"mydatabase.db\")\n", + " c = db.cursor()\n", + " request ='''SELECT * FROM CURRENCIES_METADATA'''\n", + " c.execute(request)\n", + " elem = c.fetchone()\n", + " #First test number of element\n", + " if len(elem) == 6 : \n", + " print(\"Test 2 passed : Number of element in table good\")\n", + " else : \n", + " print(\"Test failed : The number of element in the CURRENCIES_METADATA table isn't correct\")\n", + " return 0\n", + " #Then test element types\n", + " types = (int , str , str , int , int , str)\n", + " testResult = True\n", + " for i in range(len(elem)):\n", + " if type(elem[i]) != types[i]:\n", + " testResult = False\n", + " print(f'Test failed : the type of the {i} element doesn\\'t correspond, it\\'s a {type(elem[i])} but should be a {types[i]}')\n", + " return 0\n", + " if testResult: print(\"Test 3 passed : Element types good\")\n", + " return 1\n", + "\n", + "def CurrenciesMetadatGetTest():\n", + " \"\"\"Assert the first element of the CURRENCIES_METADATA table correspond to the `BTC-USD` one\"\"\"\n", + " print(\"\\n--- CURRENCIES_METADATA GET Method Test ---\")\n", + " btcusd = (1 , \"BTC-USD\" , \"CRYPTOCURRENCY\" , -1 , 0 , \"UTC\")\n", + " resget = getCurrencyMetadataElement(1)\n", + " t = np.column_stack((resget , btcusd))\n", + " for i , j in t:\n", + " if not i == j and j == -1:\n", + " print(f'Test failed : the element get by the method does not correspond to the BTC-USD one the values {i} should be {j}')\n", + " return 0\n", + " print(\"Test 4 passed : The Element Fetched Correspond\")\n", + " return 1\n", + "\n", + "def CurrenciesMetadatInsertTest():\n", + " \"\"\"Assert the neawly inserted element of the CURRENCIES_METADATA table is inserted and correct\"\"\"\n", + " print(\"\\n--- CURRENCIES_METADATA INSERT Method Test ---\")\n", + " nElem = len(currencies)\n", + " newElem = (nElem , \"newElem\" , \"CRYPTOCURRENCY\" , -1 , 0 , \"UTC\")\n", + " insertCurrencyMetadataElement(\"TPA\")\n", + " resget = getCurrencyMetadataElement(nElem)\n", + " t = np.column_stack((resget , newElem))\n", + " for i , j in t:\n", + " if not i == j and j == -1:\n", + " print(f'Test failed : the element inserted isn\\'t correct : the values {i} should be {j}')\n", + " return 0\n", + " print(\"Test 5 passed : The Element Is Inserted and is Correct\")\n", + " return 1\n", + "\n", + "def TestCurrencyTable():\n", + " \"\"\"Assert all the CURRENCIES_METADATA table structure and method are functionnal\"\"\"\n", + " return CurrenciesMetadatGeneralTest() and CurrenciesMetadatGetTest() and CurrenciesMetadatInsertTest()\n" + ] + }, + { + "cell_type": "code", + "execution_count": 12, + "metadata": {}, + "outputs": [ + { + "name": "stdout", + "output_type": "stream", + "text": [ + "--- Database General Test ---\n", + "Test 1 passed : Database exist\n", + "\n", + "--- CURRENCIES_METADATA General Test ---\n" + ] + }, + { + "ename": "TypeError", + "evalue": "object of type 'NoneType' has no len()", + "output_type": "error", + "traceback": [ + "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m", + "\u001b[0;31mTypeError\u001b[0m Traceback (most recent call last)", + "Cell \u001b[0;32mIn[12], line 10\u001b[0m\n\u001b[1;32m 7\u001b[0m \u001b[39mprint\u001b[39m(\u001b[39m\"\u001b[39m\u001b[39mTests have Failed\u001b[39m\u001b[39m\"\u001b[39m)\n\u001b[1;32m 8\u001b[0m \u001b[39mreturn\u001b[39;00m \u001b[39m0\u001b[39m\n\u001b[0;32m---> 10\u001b[0m TestDatabase()\n", + "Cell \u001b[0;32mIn[12], line 6\u001b[0m, in \u001b[0;36mTestDatabase\u001b[0;34m()\u001b[0m\n\u001b[1;32m 4\u001b[0m \u001b[39mprint\u001b[39m(\u001b[39m\"\u001b[39m\u001b[39mTests have Failed\u001b[39m\u001b[39m\"\u001b[39m)\n\u001b[1;32m 5\u001b[0m \u001b[39mreturn\u001b[39;00m \u001b[39m0\u001b[39m\n\u001b[0;32m----> 6\u001b[0m \u001b[39mif\u001b[39;00m \u001b[39mnot\u001b[39;00m TestCurrencyTable(): \n\u001b[1;32m 7\u001b[0m \u001b[39mprint\u001b[39m(\u001b[39m\"\u001b[39m\u001b[39mTests have Failed\u001b[39m\u001b[39m\"\u001b[39m)\n\u001b[1;32m 8\u001b[0m \u001b[39mreturn\u001b[39;00m \u001b[39m0\u001b[39m\n", + "Cell \u001b[0;32mIn[11], line 67\u001b[0m, in \u001b[0;36mTestCurrencyTable\u001b[0;34m()\u001b[0m\n\u001b[1;32m 65\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39mTestCurrencyTable\u001b[39m():\n\u001b[1;32m 66\u001b[0m \u001b[39m \u001b[39m\u001b[39m\"\"\"Assert all the CURRENCIES_METADATA table structure and method are functionnal\"\"\"\u001b[39;00m\n\u001b[0;32m---> 67\u001b[0m \u001b[39mreturn\u001b[39;00m CurrenciesMetadatGeneralTest() \u001b[39mand\u001b[39;00m CurrenciesMetadatGetTest() \u001b[39mand\u001b[39;00m CurrenciesMetadatInsertTest()\n", + "Cell \u001b[0;32mIn[11], line 21\u001b[0m, in \u001b[0;36mCurrenciesMetadatGeneralTest\u001b[0;34m()\u001b[0m\n\u001b[1;32m 19\u001b[0m elem \u001b[39m=\u001b[39m c\u001b[39m.\u001b[39mfetchone()\n\u001b[1;32m 20\u001b[0m \u001b[39m#First test number of element\u001b[39;00m\n\u001b[0;32m---> 21\u001b[0m \u001b[39mif\u001b[39;00m \u001b[39mlen\u001b[39;49m(elem) \u001b[39m==\u001b[39m \u001b[39m6\u001b[39m : \n\u001b[1;32m 22\u001b[0m \u001b[39mprint\u001b[39m(\u001b[39m\"\u001b[39m\u001b[39mTest 2 passed : Number of element in table good\u001b[39m\u001b[39m\"\u001b[39m)\n\u001b[1;32m 23\u001b[0m \u001b[39melse\u001b[39;00m : \n", + "\u001b[0;31mTypeError\u001b[0m: object of type 'NoneType' has no len()" + ] + } + ], + "source": [ + "def TestDatabase():\n", + " \"\"\"Assert all the database is functionnal\"\"\"\n", + " if not GeneralDatabaseTest(): \n", + " print(\"Tests have Failed\")\n", + " return 0\n", + " if not TestCurrencyTable(): \n", + " print(\"Tests have Failed\")\n", + " return 0\n", + "\n", + "TestDatabase()" + ] + } + ], + "metadata": { + "kernelspec": { + "display_name": "Python 3", + "language": "python", + "name": "python3" + }, + "language_info": { + "codemirror_mode": { + "name": "ipython", + "version": 3 + }, + "file_extension": ".py", + "mimetype": "text/x-python", + "name": "python", + "nbconvert_exporter": "python", + "pygments_lexer": "ipython3", + "version": "3.9.2" + }, + "orig_nbformat": 4, + "vscode": { + "interpreter": { + "hash": "916dbcbb3f70747c44a77c7bcd40155683ae19c65e1c03b4aa3499c5328201f1" + } + } + }, + "nbformat": 4, + "nbformat_minor": 2 +} diff --git a/Db-Script/Db-Script.py b/Db-Script/Db-Script.py new file mode 100644 index 0000000..9a1fda4 --- /dev/null +++ b/Db-Script/Db-Script.py @@ -0,0 +1,40 @@ +##Imports + +import sqlite3 as sql +import pandas as pd +import os +import datetime +import matplotlib.pyplot as plt +import numpy as np + +def createMetadataTable(): + """Create the db table which contaign all data """ + db = sql.connect("robotgowestdb.db") + c = db.cursor() + + requestCreate = '''CREATE TABLE IF NOT EXISTS METADATA_TABLE ( + [Id] INTEGER PRIMARY KEY, + [Place] TEXT, + [Start] TEXT + )''' + c.execute(requestCreate) + db.commit() + +def insertMetadataElement(place : str , start : datetime): + """Insert a new element in the metadat table + + Args: + currency (str): name of the currency to fetch its metadata with the yFinance API + """ + db = sql.connect("robotgowestdb.db") + c = db.cursor() + request = f'''INSERT INTO METADATA_TABLE (Place,Start) + VALUES ( + '{place}', + '{start}' + )''' + c.execute(request) + db.commit() + +createMetadataTable() +insertMetadataElement("ici", datetime.datetime.now()) \ No newline at end of file diff --git a/influxdb_token.txt b/influxdb_token.txt new file mode 100644 index 0000000..999500b --- /dev/null +++ b/influxdb_token.txt @@ -0,0 +1 @@ +mlxKvuIC8vZ9qQMAVxa4jD9vCLekIMFXI3tdHmx-Ho88ER1IAQfq5J1m3Rfpz_41ML6ZRSh0jZBb-aQAzoZExA== diff --git a/robotgowestdb.db b/robotgowestdb.db new file mode 100644 index 0000000..5e0cf70 Binary files /dev/null and b/robotgowestdb.db differ