Advertisement
Guest User

Untitled

a guest
Sep 6th, 2018
99
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 14.11 KB | None | 0 0
  1.                                                                                                                                                                                                                                            import pandas.io.sql as sql                                                                                                                                                                                                                  
  2. import pandas as pd                                                                                                                                                                                                                          
  3. import pyodbc                                                                                                                                                                                                                                
  4.                                                                                                                                                                                                                                              
  5. class DatabaseConnection():                                                                                                                                                                                                                  
  6.                                                                                                                                                                                                                                              
  7.     def __init__(self, server, database, username, password, driver):                                                                                                                                                                        
  8.         self._server = server                                                                                                                                                                                                                
  9.         self._database = database                                                                                                                                                                                                            
  10.         self._username = username                                                                                                                                                                                                            
  11.         self._password = password                                                                                                                                                                                                            
  12.         self._driver = driver                                                                                                                                                                                                                
  13.         self._cursor, self._cnxn = self.connect()                                                                                                                                                                                            
  14.                                                                                                                                                                                                                                              
  15.     @property                                                                                                                                                                                                                                
  16.     def server(self):                                                                                                                                                                                                                        
  17.         return self._server                                                                                                                                                                                                                  
  18.                                                                                                                                                                                                                                              
  19.     @property                                                                                                                                                                                                                                
  20.     def database(self):                                                                                                                                                                                                                      
  21.         return self._database                                                                                                                                                                                                                
  22.                                                                                                                                                                                                                                              
  23.     @property                                                                                                                                                                                                                                
  24.     def username(self):                                                                                                                                                                                                                      
  25.         return self._username                                                                                                                                                                                                                
  26.                                                                                                                                                                                                                                              
  27.     @property                                                                                                                                                                                                                                
  28.     def password(self):                                                                                                                                                                                                                      
  29.         return self._password                                                                                                                                                                                                                
  30.                                                                                                                                                                                                                                              
  31.     @property                                                                                                                                                                                                                                
  32.     def driver(self):                                                                                                                                                                                                                        
  33.         return self._driver                                                                                                                                                                                                                  
  34.                                                                                                                                                                                                                                              
  35.     @property                                                                                                                                                                                                                                
  36.     def cursor(self):                                                                                                                                                                                                                        
  37.         return self._cursor                                                                                                                                                                                                                  
  38.                                                                                                                                                                                                                                              
  39.     @property                                                                                                                                                                                                                                
  40.     def cnxn(self):                                                                                                                                                                                                                          
  41.         return self._cnxn                                                                                                                                                                                                                    
  42.                                                                                                                                                                                                                                              
  43.     def connect(self):                                                                                                                                                                                                                        
  44.         cnxn = pyodbc.connect('DRIVER={0};SERVER={1};PORT=1443;DATABASE={2};UID={3};PWD={4}'.format(self.driver, self.server, self.database, self.username, self.password))                                                                  
  45.         return cnxn.cursor(), cnxn                                                                                                                                                                                                            
  46.                                                                                                                                                                                                                                              
  47.     @staticmethod                                                                                                                                                                                                                            
  48.     def create_data_frame(table):                                                                                                                                                                                                            
  49.         df = pd.read_sql_query("SELECT * FROM NeuedaTransportData.dbo.{0}".format(table), letsConnect.cnxn)                                                                                                                                  
  50.         print df.loc                                                                                                                                                                                                                                                                                                                                                                                                                                                                        
  51.     @staticmethod                                                                                                                                                                                                                            
  52.     def display_all_tables():                                                                                                                                                                                                                
  53.         pd.read_sql_query("SELECT * FROM NeuedaTransportData.dbo.tables", letsConnect.cnxn)                                                                                                                                                  
  54.                                                                                                                                                                                                                                              
  55. if __name__ == "__main__":                                                                                                                                                                                                                    
  56.         letsConnect = DatabaseConnection("neuedadata.database.windows.net",                                                                                                                                                                  
  57.                                          "NeuedaTransportData", "neuadmin", "Weavneueda123", pyodbc.drivers()[0])                                                                                                                            
  58.         letsConnect.create_data_frame("Collision")                                                                                                                                                                                            
  59.         letsConnect.display_all_tables()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement