Initial commit

Author: iagocolodetti

.gitattributes

@@ -0,0 +1,2 @@
+# Auto detect text files and perform LF normalization
+* text=auto

.gitignore

@@ -0,0 +1,114 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.nox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+.hypothesis/
+.pytest_cache/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+db.sqlite3
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# IPython
+profile_default/
+ipython_config.py
+
+# pyenv
+.python-version
+
+# celery beat schedule file
+celerybeat-schedule
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
+
+# Pyre type checker
+.pyre/

ConnectionFactory.py

@@ -0,0 +1,20 @@
+import mysql.connector
+
+
+class ConnectionFactory:
+    def getconnection(self):
+        try:
+            con = mysql.connector.connect(
+                host="localhost",
+                port="3306",
+                user="root",
+                passwd="root",
+                database="contatodb"
+            )
+        except:
+            print('Não foi possível realizar a conexão.')
+        finally:
+            return con
+
+    def closeconnection(self, con):
+        con.close

Contato.py

@@ -0,0 +1,30 @@
+class Contato:
+    def __init__(self, id = None, nome = None, telefone = None, email = None):
+        self.__id = id
+        self.__nome = nome
+        self.__telefone = telefone
+        self.__email = email
+
+    def setid(self, id):
+        self.__id = id
+
+    def getid(self):
+        return self.__id
+
+    def setnome(self, nome):
+        self.__nome = nome
+
+    def getnome(self):
+        return self.__nome
+
+    def settelefone(self, telefone):
+        self.__telefone = telefone
+
+    def gettelefone(self):
+        return self.__telefone
+
+    def setemail(self, email):
+        self.__email = email
+
+    def getemail(self):
+        return self.__email

ContatoDAO.py

@@ -0,0 +1,152 @@
+from ConnectionFactory import *
+from Contato import *
+
+class ContatoDAO:
+    def __init__(self):
+        self.__cf = ConnectionFactory()
+
+    def add(self, contato):
+        try:
+            con = self.__cf.getconnection()
+            if con.is_connected():
+                cursor = con.cursor()
+                cursor.execute("INSERT INTO contato(nome, telefone, email) VALUES(%s, %s, %s)", (contato.getnome(), contato.gettelefone(), contato.getemail()))
+                con.commit()
+                if cursor.rowcount > 0:
+                    print('Contato adicionado.')
+                else:
+                    print('Contato não adicionado.')
+        except:
+            print('Não foi possível adicionar o contato.')
+            con.rollback()
+        finally:
+            self.__cf.closeconnection(con)
+
+    def getcontato(self, id):
+        try:
+            con = self.__cf.getconnection()
+            if con.is_connected():
+                cursor = con.cursor()
+                cursor.execute("SELECT * FROM contato WHERE id = %s", (id,))
+                result = cursor.fetchone()
+                if result is not None:
+                    contato = Contato(result[0], result[1], result[2], result[3])
+                    return contato
+                else:
+                    print('Não existe contato com esse ID.')
+        except:
+            print('Não foi possível buscar o contato.')
+        finally:
+            self.__cf.closeconnection(con)
+
+    def getcontatospornome(self, nome):
+        try:
+            con = self.__cf.getconnection()
+            if con.is_connected():
+                cursor = con.cursor()
+                cursor.execute("SELECT * FROM contato WHERE nome LIKE %s", ('%' + nome + '%',))
+                result = cursor.fetchall()
+                length = len(result)
+                if length > 0:
+                    contatos = []
+                    for i in range(length):
+                        contatos.append(Contato(result[i][0], result[i][1], result[i][2], result[i][3]))
+                    return contatos;
+                else:
+                    print('Não existem contatos com esse nome ou parte dele.')
+        except:
+            print('Não foi possível buscar os contatos.')
+        finally:
+            self.__cf.closeconnection(con)
+
+    def getcontatosportelefone(self, telefone):
+        try:
+            con = self.__cf.getconnection()
+            if con.is_connected():
+                cursor = con.cursor()
+                cursor.execute("SELECT * FROM contato WHERE telefone LIKE %s", ('%' + telefone + '%',))
+                result = cursor.fetchall()
+                length = len(result)
+                if length > 0:
+                    contatos = []
+                    for i in range(length):
+                        contatos.append(Contato(result[i][0], result[i][1], result[i][2], result[i][3]))
+                    return contatos;
+                else:
+                    print('Não existem contatos com esse telefone ou parte dele.')
+        except:
+            print('Não foi possível buscar os contatos.')
+        finally:
+            self.__cf.closeconnection(con)
+
+    def getcontatosporemail(self, email):
+        try:
+            con = self.__cf.getconnection()
+            if con.is_connected():
+                cursor = con.cursor()
+                cursor.execute("SELECT * FROM contato WHERE email LIKE %s", ('%' + email + '%',))
+                result = cursor.fetchall()
+                length = len(result)
+                if length > 0:
+                    contatos = []
+                    for i in range(length):
+                        contatos.append(Contato(result[i][0], result[i][1], result[i][2], result[i][3]))
+                    return contatos;
+                else:
+                    print('Não existem contatos com esse email ou parte dele.')
+        except:
+            print('Não foi possível buscar os contatos.')
+        finally:
+            self.__cf.closeconnection(con)
+
+    def getcontatos(self):
+        try:
+            con = self.__cf.getconnection()
+            if con.is_connected():
+                cursor = con.cursor()
+                cursor.execute("SELECT * FROM contato")
+                result = cursor.fetchall()
+                length = len(result)
+                if len(result) > 0:
+                    contatos = []
+                    for i in range(length):
+                        contatos.append(Contato(result[i][0], result[i][1], result[i][2], result[i][3]))
+                    return contatos;
+                else:
+                    print('Não existem contatos.')
+        except:
+            print('Não foi possível buscar os contatos.')
+        finally:
+            self.__cf.closeconnection(con)
+
+    def update(self, contato):
+        try:
+            con = self.__cf.getconnection()
+            if con.is_connected():
+                cursor = con.cursor()
+                cursor.execute("UPDATE contato SET nome = %s, telefone = %s, email = %s WHERE id = %s", (contato.getnome(), contato.gettelefone(), contato.getemail(), contato.getid()))
+                con.commit()
+                if cursor.rowcount > 0:
+                    print('Contato alterado com sucesso.')
+                else:
+                    print('Não existe contato com esse ID.')
+        except:
+            print('Não foi possível alterar/atualizar o contato.')
+        finally:
+            self.__cf.closeconnection(con)
+
+    def delete(self, id):
+        try:
+            con = self.__cf.getconnection()
+            if con.is_connected():
+                cursor = con.cursor()
+                cursor.execute("DELETE FROM contato WHERE id = %s", (id,))
+                con.commit()
+                if cursor.rowcount > 0:
+                    print('Contato deletado com sucesso.')
+                else:
+                    print('Não existe contato com esse ID.')
+        except:
+            print('Não foi possível excluir/remover o contato.')
+        finally:
+            self.__cf.closeconnection(con)