script.py

import time
import os
import mysql.connector
import json
import openpyxl
import csv


def connect_database(environment="development"):
    """Connect to a MySQL database."""

    connection_config = {
        "development": {
            "host": "localhost",
            "database": "local",
            "user": "main",
            "password": "main",
            "port": 10043,
        },
        "production": {
            "host": "database.example.com",
            "database": "production",
            "user": "prod_user",
            "password": "prod_password",
            "port": 3306,
        },
    }

    connection_params = connection_config[environment]

    try:
        connection = mysql.connector.connect(
            host=connection_params["host"],
            database=connection_params["database"],
            user=connection_params["user"],
            password=connection_params["password"],
            port=connection_params["port"],
        )
        return connection
    except mysql.connector.Error as error:
        print("Failed to connect to database {}".format(error))




def readJsonFile():
    try:
        f = open('content.json')
        gedItems = json.load(f)

        for entry in enumerate(gedItems):
            print(entry)
    except mysql.connector.Error as error:
        print("Failed to read json file {}".format(error))


def readJsonFileWithIndex():
    try:
        f = open('content.json')
        gedItems = json.load(f)

        for entry, index in enumerate(gedItems):
            print(entry)
    except mysql.connector.Error as error:
        print("Failed to read json file {}".format(error))

def getAllPost(connection):
    try:
        cursor = connection.cursor()
        select = "SELECT * FROM wp_posts"
        cursor.execute(select)
        result = cursor.fetchall()
        return result
    except mysql.connector.Error as error:
        print("Failed to get data from database {}".format(error))


def getPostById(connection, id):
    try:
        cursor = connection.cursor()
        select = f"SELECT * FROM wp_posts WHERE id = {id}"
        cursor.execute(select)
        result = cursor.fetchone()
    except mysql.connector.Error as error:
        print("Failed to get data from database {}".format(error))

def read_csv_file(file_path):
    try:
        with open(file_path, newline='') as csvfile:
            spamreader = csv.reader(csvfile, delimiter=';', quotechar='|')
            for row in spamreader:
                print(', '.join(row))
    except FileNotFoundError as error:
        print(f"File not found: {error}")
    except Exception as error:
        print(f"An error occurred: {error}")
    
def createPostWpPostAndReturnId(connection):
        actual_time = time.strftime('%Y-%m-%d %H:%M:%S')
        query_post = """
            INSERT INTO wp_posts (
                post_author,
                post_date,
                post_date_gmt,
                post_content,
                post_title,
                post_excerpt,
                post_name,
                to_ping,
                pinged,
                post_modified,
                post_modified_gmt,
                post_content_filtered,
                guid,
                post_type
            ) VALUES (
                1,
                '{}',
                '{}',
                'Mon contenu',
                'Post de clément',
                '',
                'post-de-clement',
                '',
                '',
                '{}',
                '{}',
                '',
                'http://test-python.local/?post_type=product&p=',
                'post'
            )
        """.format(actual_time, actual_time, actual_time)

        try:
            cursor = connection.cursor()
            cursor.execute(query_post)
            connection.commit()
            return cursor.lastrowid
        except mysql.connector.Error as error:
            print("Failed to insert data in database {}".format(error))

    

connectDatabase = connectDatabase()