Das deutsche Python-Forum

Code: Alles auswählen

import sqlite3

db_pfad = 'Z:\\02\\NGXDS_20230909.db3'
db_verbindung = sqlite3.connect(db_pfad)
db_cursor = db_verbindung.cursor()
db_cursor.execute ('SELECT * FROM NGXLIGHTNING;')
gefundene_daten = db_cursor.fetchall()

print(str(gefundene_daten))

Code: Alles auswählen

import os
import sqlite3
import datetime
from datetime import datetime, timedelta

# Heute JahrMonatTag festlegen
aktuelles_datum = datetime.now().strftime('%Y%m%d')
print("heute", aktuelles_datum)

# Datum Vortag
heute = datetime.now()
gestern = heute - timedelta (days=1)
print ("vortag", gestern.strftime ('%Y%m%d'))

# Datum Heute JahrMonatTag NGX Datenbank Format
ngx_heute = datetime.now().strftime('%Y-%m-%d')
print("ngx_heute", ngx_heute)

# Datum Vortag NGX Datenbank Format
heute = datetime.now()
ngx_gestern = heute - timedelta (days=1)
print ("ngx_vortag", ngx_gestern.strftime ('%Y-%m-%d'))

# Dateinamen mit Datum erstellen
dateiname1 = "NGXDS_" + aktuelles_datum + ".db3"
dateiname2 = "ngx_yest.db3"
dateiname3 = "ngx_today.db3"
dateiname4 = "ngx_month.db3"
dateiname5 = "ngx_year.db3"
print("test dateiname:" , dateiname1)

# Verbindung zur Datenbank herstellen
verbindung1 = sqlite3.connect(dateiname1)
# Neue Datenbank erstellen
# für gestern
verbindung2 = sqlite3.connect(dateiname2)
# für heute
verbindung3 = sqlite3.connect(dateiname3)

print("test verbindung1:" , verbindung1 )
print("test verbindung2:" , verbindung2 )
print("test verbindung3:" , verbindung3 )

# Cursor-Objekt erstellen und SQL-Abfrage zum Auslesen der Daten aus der aktuellen Datenbank
# Daten filtern
cursor = verbindung1.cursor()
cursor.execute ('SELECT SUBSTRING (datetime_utc, 1, 10), latitude, longitude, type FROM NGXLIGHTNING WHERE datetime_utc LIKE "2023-09-23%"')
daten = cursor.fetchall()

print("test ausgabe daten:" , daten )

# Aktionen bestätigen und Verbindung schließen
verbindung1.commit()
verbindung2.commit()
verbindung3.commit()
verbindung1.close()
verbindung2.close()
verbindung3.close()

Code: Alles auswählen

#!/usr/bin/env python3
import sqlite3
from contextlib import ExitStack, closing
from datetime import date as Date, datetime as DateTime

from loguru import logger


@logger.catch
def main():
    heute = DateTime.utcnow().date()
    logger.info("heute {}", heute)

    dateinamen = [
        f"NGXDS_{heute:%Y%m%d}.db3",
        "ngx_yesterday.db3",
        "ngx_today.db3",
    ]
    with ExitStack() as stack:
        (
            verbindung_heute,
            _verbindung_gestern,
            _verbindung_noch_mal_heute,  # ???
        ) = verbindungen = [
            stack.enter_context(closing(sqlite3.connect(dateiname)))
            for dateiname in dateinamen
        ]
        with verbindung_heute.cursor() as cursor:
            cursor.execute(
                "SELECT DATE(datetime_utc), latitude, longitude, type"
                " FROM ngxlightning WHERE DATE(datetime_utc) = ?",
                [Date(2023, 9, 23)],
            )
            daten = cursor.fetchall()

        logger.debug("test ausgabe daten: {}", daten)

        for verbindung in verbindungen:
            with logger.catch():
                verbindung.commit()


if __name__ == "__main__":
    main()