Skip to content

Commit b7e5ef7

Browse files
committed
fixing for newer version of pandas
1 parent b0a7fab commit b7e5ef7

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

pandasql/sqldf.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
from sqlparse.tokens import Whitespace
44
import pandas as pd
55
import numpy as np
6-
from pandas.io.sql import write_frame, frame_query
6+
from pandas.io.sql import to_sql, read_sql
77
import hashlib
88
import os
99
import re
@@ -71,7 +71,7 @@ def _write_table(tablename, df, conn):
7171
msg += "http://www.sqlite.org/lang_keywords.html"
7272
raise Exception(msg)
7373

74-
write_frame(df, name=tablename, con=conn, flavor='sqlite')
74+
to_sql(df, name=tablename, con=conn, flavor='sqlite')
7575

7676

7777
def sqldf(q, env, inmemory=True):
@@ -124,7 +124,7 @@ def sqldf(q, env, inmemory=True):
124124
_write_table(table, df, conn)
125125

126126
try:
127-
result = frame_query(q, conn)
127+
result = read_sql(q, conn)
128128
except:
129129
result = None
130130
finally:

0 commit comments

Comments
 (0)