Advertisement
Guest User

Untitled

a guest
Aug 9th, 2016
77
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.58 KB | None | 0 0
  1. import pandas as pd
  2. #Create Pandas DataFrame
  3. pd_person = pd.DataFrame({'PERSONID':'0','LASTNAME':'Doe','FIRSTNAME':'John','ADDRESS':'Museumplein','CITY':'Amsterdam'}, index=[0])
  4.  
  5. #Create Spark DataFrame from Pandas
  6. df_person = sqlContext.createDataFrame(pd_person)
  7.  
  8. #Writing Spark DataFrame to local Oracle Expression Edition 11.2.0.2
  9. #This uses the relatively older Spark jdbc DataFrameWriter api
  10. df_person.write.jdbc(url='jdbc:oracle:thin:@127.0.0.1:1521:XE', table='HR.PERSONS', mode='append', properties={'driver':'oracle.jdbc.driver.OracleDriver', 'user' : 'SYSTEM', 'password' : 'password'})
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement