Ft create database obed

.travis.yml

@@ -10,8 +10,6 @@ services:
 
 before_script:
   - psql -c "CREATE DATABASE test_nbox;" -U postgres
-  - psql -c "CREATE USER antoo WITH PASSWORD 'antoo123';" -U postgres
-  - psql -c "GRANT ALL PRIVILEGES ON DATABASE test_nbox to antoo;" -U postgres
 
 script: 
   - "python -m pytest tests/"

database.py

@@ -12,7 +12,7 @@ def session(self,):
         autocommit = True
         pass
 
-    # @abstractmethod
+    @abstractmethod
     def create_database(self):
         pass
 

db_config.py

@@ -26,6 +26,7 @@ def connect(self,database_url):
         try:
 
             connection = p.connect(database_url)
+            connection.autocommit = True
             return connection
 
         except:
@@ -41,12 +42,39 @@ def cursor(self):
         Returns:
             Object:cursor object.
         '''
+        try: 
 
-        connection = self.connect(DATABASE_URL)
-        cursor = connection.cursor()
-        return cursor
+            connection = self.connect(DATABASE_URL)
+            cursor = connection.cursor()
+            return cursor
 
+        except:
+            return 'Can not exucute PostgreSQL command'
+
+    def create_database(self, db_name):
+        """Creates a Postgres database.
+
+        Arguments:
+            db_name(str): A name of the given database.
+
+        Returns:
+            None if no exception or error mssg incase there is one. 
+        """
+
+        try: 
+
+            query = f"""CREATE DATABASE {db_name};"""
+
+            conn = self.connect(DATABASE_URL)
+            cursor = conn.cursor()
+            cursor.execute(query)
+            conn.commit()
+
+        except  :
+            return "Error while connecting to PostgreSQL"
 
 if __name__ == "__main__":
     db = PostgresConfig()
+
     print(db.connect(DATABASE_URL))
+    print(db.create_database('db_name'))

tests/integration/test_postgres.py

@@ -12,9 +12,15 @@ class PostgresTestCase(TestCase):
 
     def setUp(self):
         self.postgres = PostgresConfig()
+        self.db_name  =  "test_db_one"
 
 
     def test_make_good_connection(self):
         print(TEST_DATABASE_URL)
         self.assertNotEqual(self.postgres.connect(TEST_DATABASE_URL),
                             'failed to connect to database.')
+
+    def test_create_database(self):
+        self.assertNotIn(self.postgres.create_database(self.db_name), 'failed to connect to database.'
+      )
+