Add files via upload

Author: MitkoVtori

ConsoleSQL.py

@@ -0,0 +1,393 @@
+import os
+import errors
+
+
+def documentation():
+    pass
+
+
+def create_database(database, *args):
+    '''
+        Console command
+        CREATE DATABASE DataBaseName
+    '''
+
+    try:
+
+        os.mkdir(f"databases/{database}"), os.mkdir(f"databases/{database}/files"), os.mkdir(f"databases/{database}/tables")
+
+    except FileExistsError:
+        return "Database already exists"
+
+    return f"Database \"{database}\" was created"
+
+
+def use_database(database, *args):
+    '''
+        Console command
+        USE DATABASE DataBaseName
+    '''
+
+    if os.path.exists(f"databases/{database}/"):
+        return [f"Currently working with database \"{database}\"", database]
+
+    raise errors.DataBaseNotFoundError(f"Database \"{database}\" not found!")
+
+
+def create_table(database, table, values, *args):
+    '''
+        Console command
+        CREATE TABLE TableName(id: int, name: str, age: float, more...)
+    '''
+
+    if os.path.exists(f"databases/{database}/tables/{table}.txt"):
+        return f"Table already exists!"
+
+    table = open(f"databases/{database}/tables/{table}.txt", "a+")
+    table.write(f"{values}\n\n")
+    table.close()
+
+    return f"Table \"{table}\" was created!"
+
+
+def add_content_to_table(database, table, *content):
+    '''
+        Console command
+
+        ADD TableName VALUES (
+        (id, name, age, more...)
+        (id, name, age)
+        );
+
+    '''
+
+    try:
+
+        with open(f"databases/{database}/tables/{table}.txt", "r") as file:
+
+            values = [line for line in file][0]
+            values_dictionary = {}
+
+            for item in values[1:-2].split(", "):
+
+                key, value = item.split(": ")
+                values_dictionary[key] = value
+
+            with open(f"databases/{database}/tables/{table}.txt", "a+") as write_file:
+
+                for content_list in content:
+
+                    content_dict = {}
+
+                    for index, item in enumerate(values_dictionary.keys()):
+
+                        content_dict[item] = content_list[index]
+
+                        if type(content_dict[item]) is int and values_dictionary[item] == "'int'" or \
+                                type(content_dict[item]) is str and values_dictionary[item] == "'str'" or \
+                                    type(content_dict[item]) is float and values_dictionary[item] == "'float'":
+                                        continue
+
+                        raise errors.ItemValueDifferentThanTheSetValue(f"item \"{item}\" is type \'{type(content_dict[item])}\' and it must be \'{values_dictionary[item]}\'")
+
+                    write_file.write(f"{content_dict}\n")
+
+    except Exception as e:
+        raise e
+
+    return "Content added to table!"
+
+
+def create_file(database, file_name):
+    '''
+        Console command
+        CREATE FILE FileName
+    '''
+
+    if os.path.exists(f"databases/{database}/files/{file_name}.txt"):
+        return "File already exists"
+
+    file = open(f"databases/{database}/files/{file_name}.txt", 'x')
+    file.close()
+
+    return f"File \"{file_name}\" was created!"
+
+
+def write_in_file(database, file, *content):
+    '''
+        Console command
+        WRITE IN FileName:
+        Something isn't right.
+        Some Messages!
+        content, content, content,
+        content, content,
+        content,
+        content,
+        content;;;
+    '''
+
+    if os.path.exists(f"databases/{database}/files/{file}.txt"):
+        with open(f"databases/{database}/files/{file}.txt", "a+") as f:
+            for line in content:
+                f.write(f"{line}\n")
+
+        return "Content added to file!"
+
+    return f"Database \"{database}\" or File \"{file}\" not found!"
+
+
+def check_table_content(database, table, *border):
+    '''
+        Console command
+
+        without border: GET ALL TableName
+        with border: GET 3 TableName # border equals 3, gets the first three lines
+    '''
+
+    if os.path.exists(f"databases/{database}/tables/{table}.txt"):
+        file = open(f"databases/{database}/tables/{table}.txt", "r")
+
+        if border:
+            if type(border[0]) is int:
+                if border[0] < len([line for line in file]):
+                    return [line for line in file[3:border[0]+4]]
+
+        return [line for line in file[3:]]
+
+    print("Table not found!")
+    return []
+
+
+def check_file_content(database, file_name, *border):
+    '''
+        Console command
+
+        without border: GET FILE FileName
+        with border: GET FILE FileName 3 # border equals 3, gets the first three lines
+    '''
+
+    if os.path.exists(f"databases/{database}/files/{file_name}.txt"):
+        file = open(f"databases/{database}/tables/{file_name}.txt", "r")
+
+        if border:
+            if type(border[0]) is int:
+                if border[0] < len([line for line in file]):
+                    return [line for line in file[:border[0] + 1]]
+
+        return [line for line in file]
+
+    print("File not found!")
+    return []
+
+
+def drop_database(*databases):
+    '''
+        Console command
+
+        One DataBase:
+            FIRST WAY: DROP DB DataBaseName
+            SECOND WAY: DROP DATABASE DataBaseName
+
+        More Than One DataBases:
+            FIRST WAY: DROP DBS FirstDataBaseName SecondDataBaseName ThirdDataBaseName...
+            SECOND WAY: DROP DATABASES FirstDataBaseName SecondDataBaseName ThirdDataBaseName...
+    '''
+
+    for db in databases:
+        if os.path.exists(f"databases/{db}/"):
+            os.remove(f"databases/{db}/")
+
+    return "Database/s dropped!"
+
+
+def drop_table(database, *tables):
+    '''
+        Console command
+
+        One Table:
+            DROP TABLE TableName
+
+        More Than One Table:
+            DROP TABLES FirstTableName SecondTableName ThirdTableName...
+    '''
+
+    for table in tables:
+        if os.path.exists(f"databases/{database}/tables/{table}.txt"):
+            os.remove(f"databases/{database}/tables/{table}.txt")
+
+    return "Table/s dropped!"
+
+
+def delete_file(database, *files):
+    '''
+            Console command
+
+            One File:
+                DEL FILE TableName
+
+            More Than One File:
+                DEL FILES FirstFileName SecondFileName ThirdFileName...
+        '''
+
+    for file in files:
+        if os.path.exists(f"databases/{database}/files/{file}.txt"):
+            os.remove(f"databases/{database}/files/{file}.txt")
+
+    return "File/s deleted!"
+
+
+def code_saver(user_input, code_file, new_line):
+    '''
+        Saves the code in the code file.
+    '''
+
+    file = open(f"src/{code_file}", "a+")
+    file.write(f"{user_input}{new_line}")
+    file.close()
+
+
+def run_program():
+    while True:
+        file = input("Create or choose file where to save the code from your console experience:\n")
+
+        if not os.path.exists(f"src/{file}.txt"):
+            f = open(f"src/{file}.txt", "x")
+            f.close()
+
+        if file:
+            break
+
+    file = f"{file}.txt"
+
+    while True:
+
+        operation_code = input()
+        operation = operation_code.lower().split()
+
+        code_saver(operation_code, file, '\n')
+
+        if operation_code == "END":
+            break
+
+        if operation_code == "docs":
+            print(documentation().__doc__())
+
+        if len(operation) >= 3:
+            if operation[-1]:
+
+                if operation[:-1] == ["create", "database"]:
+                    print(create_database(operation[-1]))
+
+                elif operation[:-1] == ["use", "database"]:
+
+                    db = use_database(operation[-1])
+                    print(db[0])
+                    database = db[-1]
+
+                elif operation[:2] == ["create", "table"]:
+
+                    table_name = ' '.join(operation[2:])[:' '.join(operation[2:]).index("(")]
+                    values = ' '.join(operation[2:])[' '.join(operation[2:]).index("(")+1:' '.join(operation[2:]).index(")")]
+                    values_tuple = values.split(", ")
+                    values_dict = {}
+
+                    for items in values_tuple:
+
+                        key, value = items.split(": ")
+                        values_dict[key] = value
+
+                    print(create_table(database, table_name, values_dict))
+
+                elif operation[0] == "add" and operation[-2] == "values":
+
+                    table = operation[1]
+
+                    if operation[-1] == "(":
+
+                        lst_values = []
+                        item = input()
+
+                        while item != ");":
+
+                            code_saver(item, file, '\n')
+                            items = item[1:-1].split(", ")
+
+                            for index in range(len(items)):
+
+                                if len(items[index].split(".")) == 2:
+                                    if items[index].split(".")[0].isdigit() and items[index].split(".")[1].isdigit():
+                                        items[index] = float(items[index])
+
+                                elif items[index].isdigit():
+                                    items[index] = int(items[index])
+
+                            lst_values.append(items)
+                            item = input()
+
+                        code_saver(item, file, '\n\n\n')
+                        print(add_content_to_table(database, table, *lst_values))
+
+                elif operation[:-1] == ["create" "file"]:
+                    print(create_file(database, operation[-1]))
+
+                elif operation[:-1] == ["write", "in"]:
+
+                    content = []
+                    text = input()
+
+                    while text[-3:] != ";;;":
+
+                        code_saver(text, file, '\n')
+                        content.append(text)
+                        text = input()
+
+                    content.append(text)
+
+                    if operation[-1][-1] == ':':
+                        print(write_in_file(database, operation[-1][:-1], content))
+
+                    else:
+                        print(write_in_file(database, operation[-1], content))
+
+                    code_saver(content, file, '\n\n\n')
+
+                elif operation[0] == "get" and operation[1] == "all":
+
+                    lines = check_table_content(database, operation[1])
+                    print()
+                    [print(line) for line in lines]
+
+                elif operation[0] == "get" and operation[1].isdigit():
+
+                    lines = check_table_content(database, operation[-1], int(operation[1]))
+                    print()
+                    [print(line) for line in lines]
+
+                elif operation[:-1] == ["get", "file"]:
+
+                    lines = check_file_content(database, operation[-1])
+                    print()
+                    [print(line) for line in lines]
+
+                elif operation[:-2] == ["get", "file"]:
+
+                    lines = check_file_content(database, operation[-2], int(operation[-1]))
+                    print()
+                    [print(line) for line in lines]
+
+                elif operation[:-1] == ["drop", "db"] or operation[:-1] == ["drop", "database"] or operation[:2] == \
+                    ["drop", "dbs"] or operation[:2] == ["drop", "databases"]:
+
+                    dbs = operation[2:]
+                    print(drop_database(*dbs))
+
+                elif operation[:2] == ["drop", "table"] or operation[:2] == ["drop", "tables"]:
+                    print(drop_table(database, *operation[2:]))
+
+                elif operation[:2] == ["del", "file"] or operation[:2] == ["del", "files"]:
+                    print(delete_file(database, *operation[2:]))
+
+    code_saver('\n// everything bellow is made on new run.', file, '\n')
+
+
+run_program()

databases/mydb/tables/mytable.txt

@@ -0,0 +1,3 @@
+{'id': 'int', 'name': 'str', 'age': 'int'}
+
+{"'id'": 1, "'name'": 'gosheto', "'age'": 17}