# 線上賣圖書(shū)
    -圖書(shū)表  圖書(shū)名字，圖書(shū)價(jià)格，庫(kù)存字段
    -訂單表： 訂單id，訂單名字
# 表準(zhǔn)備
    class Book(models.Model):
        name = models.CharField(max_length=32)
        price = models.IntegerField()  #
        count = models.SmallIntegerField(verbose_name='庫(kù)存')
    class Order(models.Model):
        order_id = models.CharField(max_length=64)
        order_name = models.CharField(max_length=32)
# 使用mysql
DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'lqz',
        'HOST': '127.0.0.1',
        'PORT': '3306',
        'USER': 'lqz',
        'PASSWORD': '123',
    }
}
# 創(chuàng)建lqz數(shù)據(jù)庫(kù)

begin; # 開(kāi)啟事務(wù)
select * from goods where id = 1 for update;  # 行鎖
# order表中加數(shù)據(jù)
update goods set stock = stock - 1 where id = 1; # 更新
commit; #提交事務(wù)

#1  使用悲觀鎖實(shí)現(xiàn)下單
@transaction.atomic  # 整個(gè)過(guò)程在一個(gè)事物中---》改兩個(gè)表：book表減庫(kù)存，訂單表生成記錄
def seckill(request):
    # 鎖住查詢到的book對(duì)象，直到事務(wù)結(jié)束
    sid = transaction.savepoint() # 保存點(diǎn)
    # 悲觀鎖： select_for_update()
    # 加鎖了--》行鎖還是表鎖？ 分情況，都有可能
    #
    book = Book.objects.select_for_update().filter(pk=1).first()  # 加悲觀鎖,行鎖，鎖住當(dāng)前行
    if book.count > 0:
        print('庫(kù)存可以，下單')
        # 訂單表插入一條
        Order.objects.create(order_id=str(datetime.datetime.now()), order_name='測(cè)試訂單')
        # 庫(kù)存-1，扣減的時(shí)候，判斷庫(kù)存是不是上面查出來(lái)的庫(kù)存，如果不是，就回滾
        time.sleep(random.randint(1, 4))  # 模擬延遲
        book.count=book.count-1
        book.save()
        transaction.savepoint_commit(sid)  # 提交，釋放行鎖
        return HttpResponse('秒殺成功')
    else:
        transaction.savepoint_rollback(sid) #回滾，釋放行鎖
        return HttpResponse('庫(kù)存不足，秒殺失敗')

# 2 樂(lè)觀鎖秒殺--普通版
@transaction.atomic
def seckill(request):
    # 鎖住查詢到的book對(duì)象，直到事務(wù)結(jié)束
    sid = transaction.savepoint()
    book = Book.objects.filter(pk=1).first()  # 沒(méi)加鎖
    count = book.count
    print('現(xiàn)在的庫(kù)存為：%s' % count)
    if book.count > 0:
        print('庫(kù)存可以，下單')
        Order.objects.create(order_id=str(datetime.datetime.now()), order_name='測(cè)試訂單-樂(lè)觀鎖')
        # 庫(kù)存-1，扣減的時(shí)候，判斷庫(kù)存是不是上面查出來(lái)的庫(kù)存，如果不是，就回滾
        # time.sleep(random.randint(1, 4))  # 模擬延遲
        res = Book.objects.filter(pk=1, count=count).update(count=count - 1)
        if res >= 1:  # 表示修改成功
            transaction.savepoint_commit(sid)
            return HttpResponse('秒殺成功')
        else:  # 修改不成功，回滾
            transaction.savepoint_rollback(sid)
            return HttpResponse('被別人改了，回滾，秒殺失敗')
    else:
        transaction.savepoint_rollback(sid)
        return HttpResponse('庫(kù)存不足，秒殺失敗')