|
'''线程和进程''' from multiprocessing import Process import os,time def run(name): print('运行子进程%s(%s)'%(name,os.getpid())) def run2(name): print('运行子进程%s(%s)'%(name,os.getpid())) if __name__ == "__main__": print('当前进程是%s'%os.getpid()) # run('test') # 这行代码仍然在当前进程中执行 # 创建一个新的进程 p = Process(target=run,args=('test',)) # 开始执行新进程 print('开始执行子进程') p.start() # time.sleep(1) # 将子进程加入到主进程当中 p.join() print('子进程执行完毕') p2 = Process(target=run2,args=('demo',)) p2.start() p2.join()
'''线程''' import threading,time def task(name): print('线程%s正在运行...'%threading.current_thread().name) print(name) if __name__ == "__main__": print('主线程是%s'%threading.current_thread().name) # task() # 创建一个新线程 t = threading.Thread(target=task,args=('传入一个参数',)) t.start() t.join() print('主线程%s运行结束'%threading.current_thread().name)
import mysql.connector # 连接数据库 db = mysql.connector.connect(host='localhost',user='root',password='zrl5157659') # 获取游标 cursor =db.cursor() # 创建数据库 cursor.execute('CREATE DATABASE JY40') ''' ACID Atomic 原子性 Conisitence 一致性 Isolation 隔离性 Duration 持久性 '''
import mysql.connector db = mysql.connector.connect(host='localhost',user='root',password='zrl5157659',database='JY40') # 获取游标 cursor = db.cursor() # 添加一个user表 cursor.execute('''CREATE TABLE IF NOT EXISTS USER( id INT PRIMARY KEY AUTO_INCREMENT, NAME VARCHAR(50) UNIQUE NOT NULL, pwd VARCHAR(50) NOT NULL )''' ) # 添加数据 cursor.execute('insert into user(name,pwd) VALUES("tom","123")') # 提交 db.commit()
| 
