import subprocess
def execute_sql_plus(sql_plus_cmd):
p = subprocess.Popen(sql_plus_cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
out, err = p.communicate()
if p.returncode != 0:
raise Exception("failed to execute sql")
return out
out = execute_sql_plus(
"sqlplus -S user/pwd@dbname < ")
print(out.decode("utf-8"))