getDFbyRDBMS.py

'''
Function to Create Dataframe on RDBMS Table
Parameters: SparkSession Object, DB Username, DB password, JDBC Driver ClassName, JDBC URL, Query to run
Return: Spark Dataframe
'''
def getDFbyRDBMS(spark, user, password, driver, jdbcURL, readQuery):
  prop = {"user":user, "password":password, "driver": driver, "sslConnection":"false"}
  df = spark.read.jdbc(url = jdbcURL, table = readQuery, properties = prop)
  return df