V2EX › gdsagdada 的所有回复 › 第 9 页 / 共 16 页

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

1 2 3 4 5 6 7 8 9 10 ... 16

❮

❯

2017-01-19 11:52:15 +08:00

回复了 thekoc 创建的主题 › Python › sqlite3 多线程高并发的访问如何处理？

楼主改 py2 了记得也贴下

2017-01-19 11:50:02 +08:00

回复了 thekoc 创建的主题 › Python › sqlite3 多线程高并发的访问如何处理？

# coding:utf-8
import sqlite3
import queue, os

def singleton(cls):
instances = {}

def _singleton(*args, **kw):
if cls not in instances:
instances[cls] = cls(*args, **kw)
return instances[cls]

return _singleton

@singleton
class SQLiteUtil(object):
__queue_conn = queue.Queue(maxsize=1)
__path = None

def __init__(self, path):
self.__path = path
print('path:', self.__path)
self.__create_conn()

def __create_conn(self):
conn = sqlite3.connect(self.__path, check_same_thread=False)
self.__queue_conn.put(conn)

def __close(self, cursor, conn):
if cursor is not None:
cursor.close()
if conn is not None:
cursor.close()
self.__create_conn()

def execute_query(self, sql, params):
conn = self.__queue_conn.get()
cursor = conn.cursor()
value = None
try:
records = None
if not params is None:
records = cursor.execute(sql, params).fetchall()
else:
records = cursor.execute(sql).fetchall()
field = [i[0] for i in cursor.description]
value = [dict(zip(field, i)) for i in records]
finally:
self.__close(cursor, conn)
return value

def executescript(self, sql):
conn = self.__queue_conn.get()
cursor = conn.cursor()
try:
cursor.executescript(sql)
conn.commit()
except Exception as e:
conn.rollback()
raise
finally:
self.__close(cursor, conn)

def execute_update(self, sql, params):
return self.execute_update_many([sql], [params])

def execute_update_many(self, sql_list, params_list):
conn = self.__queue_conn.get()
cursor = conn.cursor()
count = 0
try:
for index in range(len(sql_list)):
sql = sql_list[index]
params = params_list[index]
if not params is None:
count += cursor.execute(sql, params).rowcount
else:
count += cursor.execute(sql).rowcount
conn.commit()
except Exception as e:
conn.rollback()
raise
finally:
self.__close(cursor, conn)
return count

'''
example:

one = SQLiteUtil('xxx.sqlite')

rst = one.execute_query('select * from website', None)
for line in rst:
print(line.get('id'), line.get('url'), line.get('content'))

print(one.execute_update('update website set content = \'2222222\' where id = ?', ('1',)))
print(one.execute_update('update website set content = \'2222222\' where id = \'1\'', None))

print('update many')
count = one.execute_update_many(
[
'update website set content = \'一\' where id = \'1\'',
'update website set content = \'二\' where id = \'2\'',
'update website set content = 1 where id = \'3\''
],
[None, None, None]
)
print('count:', count)
'''

python3 的用 py2 自己改改，可抗千万级并发[v2ex 滑稽专属表情]

2017-01-19 11:31:54 +08:00

回复了 dettac 创建的主题 › Wikipedia › 如何下载特定的 wikipedia 数据？

https://www.zhihu.com/question/19803440
问前先搜索，爬虫不现实

2017-01-19 11:26:34 +08:00

回复了 xcatliu 创建的主题 › 分享创造 › 随手撸了个测试屏幕坏点的网页

去掉所有文字，单击换色，方可解决所有设备

2017-01-18 18:11:45 +08:00

回复了 makeitall 创建的主题 › 程序员 › imagemagick 水印 gif 时候遇到的问题（内详有图）

可能因为 gif 帧大小不一样

2017-01-18 18:07:44 +08:00

回复了 cheetah 创建的主题 › 问与答 › 有什么服务可以让我方便的给网站加一个捐助页面吗？

楼主要不贴我的微信二维码，支付宝也行，比特币 paypal 也还行