京东自研电商数据库内核DongSQL简介

-- INSERT操作返回自增IDINSERT INTO orders (customer_id, order_date) VALUES (1001, NOW()) RETURNING order_id;-- UPDATE操作返回更新后的数据UPDATE products SET price = price * 1.1 WHERE category = 'electronics' RETURNING product_id, name, old_price, price;-- DELETE操作返回被删除的记录DELETE FROM expired_sessions WHERE expire_time < NOW() RETURNING session_id, user_id, expire_time;

-- 库存扣减：确保只影响一行，成功自动提交，失败自动回滚UPDATE /*+ TARGET_AFFECT_ROW(1) COMMIT_ON_SUCCESS ROLLBACK_ON_FAIL */inventory SET stock = stock - 5 WHERE product_id = 1001 AND stock >= 5;

-- 对商品ID为999的热门商品进行限流，并发度限制为5SELECT /*+ ccl_queue_value(999, 5) */ * FROM products WHERE product_id = 999;-- 对库存扣减操作按商品ID进行限流UPDATE /*+ ccl_queue_field(product_id, 8) */ inventory SET stock = stock - 1 WHERE product_id = ?;-- 对相同SQL模式进行统一限流SELECT /*+ ccl_queue_digest(10) */ * FROM hot_products WHERE status = 1;

-- 为重要SQL固化执行计划CALL dbms_outln.add_index_outline(  'test_db', '', 1, 'USE INDEX', 'idx_status', '',  'SELECT * FROM orders WHERE status = "PAID"');-- 为特定查询添加ccl_queue_digest限流hint，限制并发度为2CALL dbms_outln.add_optimizer_outline(  'test_db', '', 1, '/*+ ccl_queue_digest(2) */',  'SELECT * FROM orders WHERE customer_id = 1001');