pg数据库for循环_oracle执行for循环插数据

Select for update使用详解 　　前言 　　近期开发与钱相关的项目，在高并发场景下对数据的准确行有很高的要求，用到了for update，故总结一波以便日后留恋。 　　for update的使用场景 　　如果遇到存在高并发并且对于数据的准确性很有要求的场景，是需要了解和使用for update的。 　　比如涉及到金钱、库存等。一般这些操作都是很长一串并且是开启事务的。如果库存刚开始读的时候是1，而立马另一个进程进行了update将库存更新为0了，而事务还没有结束，会将错的数据一直执行下去，就会有问题。所以需要for upate 进行数据加锁防止高并发时候数据出错。 　　记住一个原则：一锁二判三更新 　　排他锁的申请前提 　　没有线程对该结果集中的任何行数据使用排他锁或共享锁，否则申请会阻塞。 　　for update仅适用于InnoDB，且必须在事务块(BEGIN/COMMIT)中才能生效。在进行事务操作时，通过“for update”语句，MySQL会对查询结果集中每行数据都添加排他锁，其他线程对该记录的更新与删除操作都会阻塞。排他锁包含行锁、表锁。 　　场景分析 　　假设有一张商品表 goods，它包含 id，商品名称，库存量三个字段，表结构如下： 　　CREATE TABLE `goods` ( 　　`id` int(11) NOT NULL AUTO_INCREMENT, 　　`name` varchar(100) DEFAULT NULL, 　　`stock` int(11) DEFAULT NULL, 　　PRIMARY KEY (`id`), 　　UNIQUE KEY `idx_name` (`name`) USING HASH 　　) ENGINE=InnoDB 　　插入如下数据： 　　INSERT INTO `goods` VALUES (‘1’, ‘prod11’, ‘1000’); 　　INSERT INTO `goods` VALUES (‘2’, ‘prod12’, ‘1000’); 　　INSERT INTO `goods` VALUES (‘3’, ‘prod13’, ‘1000’); 　　INSERT INTO `goods` VALUES (‘4’, ‘prod14’, ‘1000’); 　　INSERT INTO `goods` VALUES (‘5’, ‘prod15’, ‘1000’); 　　INSERT INTO `goods` VALUES (‘6’, ‘prod16’, ‘1000’); 　　INSERT INTO `goods` VALUES (‘7’, ‘prod17’, ‘1000’); 　　INSERT INTO `goods` VALUES (‘8’, ‘prod18’, ‘1000’); 　　INSERT INTO `goods` VALUES (‘9’, ‘prod19’, ‘1000’); 　　一、数据一致性 　　假设有A、B两个用户同时各购买一件 id=1 的商品，用户A到的库存量为 1000，用户B到的库存量也为 1000，用户A完成购买后修改该商品的库存量为 999，用户B完成购买后修改该商品的库存量为 999，此时库存量数据产生了不一致。 　　有两种解决方案： 　　悲观锁方案：每次商品时，对该商品加排他锁。也就是在用户A id=1 的商品信息时对该行记录加锁，期间其他用户阻塞等待访问该记录。悲观锁适合写入频繁的场景。 　　begin; 　　select * from goods where id = 1 for update; 　　update goods set stock = stock – 1 where id = 1; 　　commit; 　　乐观锁方案：每次商品时，不对该商品加锁。在更新数据的时候需要比较程序中的库存量与数据库中的库存量是否相等，如果相等则进行更新，反之程序重新库存量，再次进行比较，直到两个库存量的数值相等才进行数据更新。乐观锁适合读取频繁的场景。 　　#不加锁 id=1 的商品对象 　　select * from goods where id = 1 　　begin; 　　#更新 stock 值，这里需要注意 where 条件 “stock = cur_stock”，只有程序中到的库存量与数据库中的库存量相等才执行更新 　　update goods set stock = stock – 1 where id = 1 and stock = cur_stock; 　　commit; 　　如果我们需要设计一个商城系统，该选择以上的哪种方案呢？ 　　查询商品的频率比下单支付的频次高，基于以上我可能会优先考虑第二种方案（当然还有其他的方案，这里只考虑以上两种方案）。 　　二、行锁与表锁 　　InnoDB默认是行级别的锁，当有明确指定的主键时候，是行级锁。否则是表级别。 　　#for update的注意点for update 仅适用于InnoDB，并且必须开启事务，在begin与commit之间才生效。 　　要测试for update的锁表情况，可以利用MySQL的Command Mode，开启二个视窗来做测试。 　　1、只根据主键进行查询，并且查询到数据，主键字段产生行锁。 　　begin; 　　select * from goods where id = 1 for update; 　　commit; 　　2、只根据主键进行查询，没有查询到数据，不产生锁。 　　begin; 　　select * from goods where id = 1 for update; 　　commit; 　　3、根据主键、非主键含索引（name）进行查询，并且查询到数据，主键字段产生行锁，name字段产生行锁。 　　begin; 　　select * from goods where id = 1 and name=’prod11′ for update; 　　commit; 　　4、根据主键、非主键含索引（name）进行查询，没有查询到数据，不产生锁。 　　begin; 　　select * from goods where id = 1 and name=’prod12′ for update; 　　commit; 　　5、根据主键、非主键不含索引（name）进行查询，并且查询到数据，如果其他线程按主键字段进行再次查询，则主键字段产生行锁，如果其他线程按非主键不含索引字段进行查询，则非主键不含索引字段产生表锁，如果其他线程按非主键含索引字段进行查询，则非主键含索引字段产生行锁，如果索引值是枚举类型，mysql也会进行表锁，这段话有点拗口，大家仔细理解一下。 　　begin; 　　select * from goods where id = 1 and name=’prod11′ for update; 　　commit; 　　6、根据主键、非主键不含索引（name）进行查询，没有查询到数据，不产生锁。 　　begin; 　　select * from goods where id = 1 and name=’prod12′ for update; 　　commit; 　　7、根据非主键含索引（name）进行查询，并且查询到数据，name字段产生行锁。 　　begin; 　　select * from goods where name=’prod11′ for update; 　　commit; 　　8、根据非主键含索引（name）进行查询，没有查询到数据，不产生锁。 　　begin; 　　select * from goods where name=’prod11′ for update; 　　commit; 　　9、根据非主键不含索引（stock）进行查询，并且查询到数据，stock字段产生表锁。 　　begin; 　　select * from goods where stock=’1000′ for update; 　　commit; 　　10、根据非主键不含索引（stock）进行查询，没有查询到数据，stock字段产生表锁。 　　begin; 　　select * from goods where stock=’2000′ for update; 　　commit; 　　11、只根据主键进行查询，查询条件为不等于，并且查询到数据，主键字段产生表锁。 　　begin; 　　select * from goods where id <> 1 for update; 　　commit; 　　12、只根据主键进行查询，查询条件为不等于，没有查询到数据，主键字段产生表锁。 　　begin; 　　select * from goods where id <> 1 for update; 　　commit; 　　13、只根据主键进行查询，查询条件为 like，并且查询到数据，主键字段产生表锁。 　　begin; 　　select * from goods where id like ‘1’ for update; 　　commit; 　　14、只根据主键进行查询，查询条件为 like，没有查询到数据，主键字段产生表锁。 　　begin; 　　select * from goods where id like ‘1’ for update; 　　commit; 　　测试环境 　　数据库版本：5.1.48-community 　　数据库引擎：InnoDB Supports transactions, row-level locking, and foreign keys 　　数据库隔离策略：REPEATABLE-READ（系统、会话） 　　总结 　　1、InnoDB行锁是通过给索引上的索引项加锁来实现的，只有通过索引条件检索数据，InnoDB才使用行级锁，否则，InnoDB将使用表锁。 　　2、由于MySQL的行锁是针对索引加的锁，不是针对记录加的锁，所以虽然是访问不同行的记录，但是如果是使用相同的索引键，是会出现锁冲突的。应用设计的时候要注意这一点。 　　3、当表有多个索引的时候，不同的事务可以使用不同的索引锁定不同的行，另外，不论是使用主键索引、唯一索引或普通索引，InnoDB都会使用行锁来对数据加锁。 　　4、即便在条件中使用了索引字段，但是否使用索引来检索数据是由MySQL通过判断不同执行计划的代价来决定的，如果MySQL认为全表扫描效率更高，比如对一些很小的表，它就不会使用索引，这种情况下InnoDB将使用表锁，而不是行锁。因此，在分析锁冲突时，别忘了检查SQL的执行计划，以确认是否真正使用了索引。 　　5、检索值的数据类型与索引字段不同，虽然MySQL能够进行数据类型转换，但却不会使用索引，从而导致InnoDB使用表锁。通过用explain检查两条SQL的执行计划，我们可以清楚地看到了这一点。