sql mysql数据库导库 panda pymysql
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了sql mysql数据库导库 panda pymysql,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含1157字,纯文字阅读大概需要2分钟。
内容图文
![sql mysql数据库导库 panda pymysql](/upload/InfoBanner/zyjiaocheng/879/e4e16fb5301d420ba750791fa305e53b.jpg)
mysql数据库 导入数据
1. panda
效率超高 对内存要求高 网络稳定性
# 读取文件
ratings_names = ['user_id', 'movie_id', 'ratings', 'rating_time']
ratings = pd.read_table('/home/qjun/桌面/movielens/ratings.dat',
sep='::', header=None, engine='python',
names=ratings_names)
# 存到sql
ratings.to_sql('ratings',db, index=False, if_exists='append')
2.pymysql
import pymysql
class DB:
def __init__(self):
self.con = None
self._get_con()
def _get_con(self):
self.con = pymysql.connect(host='localhost', port=3306,
database='movielens', charset='utf8',
user='root', password='123456')
def insert_ratings(self, user_id, movie_id, rating, rating_time):
try:
with self.con.cursor() as cursor:
result = cursor.execute(
'insert into tb_ratings values (%s, %s, %s, %s)',
(user_id, movie_id, rating, rating_time)
)
if result == 1:
print('添加成功!')
self.con.commit()
finally:
print('!!!!!!'*20)
# self.con.close()
def ratings2sql():
with open('ratings.dat', 'r') as f:
data, count = None, 0
db = DB()
while True:
count += 1
data = f.readline().strip()
if not data:
break
data = data.split('::')
print(data)
db.insert_ratings(data[0], data[1], data[2], data[3])
print(count)
if __name__ == '__main__':
ratings2sql()
内容总结
以上是互联网集市为您收集整理的sql mysql数据库导库 panda pymysql全部内容,希望文章能够帮你解决sql mysql数据库导库 panda pymysql所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。