如何在mysql 的存儲(chǔ)過(guò)程中使用事務(wù)

6.7 MySQL 事務(wù)與鎖定命令

創(chuàng)新互聯(lián)公司是一家專(zhuān)業(yè)提供平桂企業(yè)網(wǎng)站建設(shè),專(zhuān)注與成都網(wǎng)站建設(shè)、網(wǎng)站制作、H5網(wǎng)站設(shè)計(jì)、小程序制作等業(yè)務(wù)。10年已為平桂眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專(zhuān)業(yè)網(wǎng)站制作公司優(yōu)惠進(jìn)行中。

6.7.1 BEGIN/COMMIT/ROLLBACK 句法

缺省的，MySQL 運(yùn)行在 autocommit 模式。這就意味著，當(dāng)你執(zhí)行完一個(gè)更新時(shí)，MySQL 將立刻將更新存儲(chǔ)到磁盤(pán)上。

如果你使用事務(wù)安全表 (例如 InnoDB、BDB)，通過(guò)下面的命令，你可以設(shè)置 MySQL 為非 autocommit 模式：

SET AUTOCOMMIT=0

在此之后，你必須使用 COMMIT 來(lái)存儲(chǔ)你的更改到磁盤(pán)上，或者使用 ROLLBACK ，如果你希望忽略從你的事務(wù)開(kāi)始所做的更改。

如果你希望為一系列語(yǔ)句從 AUTOCOMMIT 模式轉(zhuǎn)換，你可以使用 START TRANSACTION 或 BEGIN 或 BEGIN WORK 語(yǔ)句：

START TRANSACTION;

SELECT @A:=SUM(salary) FROM table1 WHERE type=1;

UPDATE table2 SET summmary=@A WHERE type=1;

COMMIT;

START TRANSACTION 在 MySQL 4.0.11 中被加入；這是被推薦的開(kāi)始一個(gè)特別(ad-hoc)事務(wù)的方式，因?yàn)檫@是 ANSI SQL 句法。

注意，如果你使用的是一個(gè)非事務(wù)安全表，更改會(huì)立刻被存儲(chǔ)，不受 autocommit 模式狀態(tài)的約束。

當(dāng)你更新了一個(gè)非事務(wù)表后，如果你執(zhí)行一個(gè) ROLLBACK，你將得到一個(gè)錯(cuò)誤 (ER_WARNING_NOT_COMPLETE_ROLLBACK) 作為一個(gè)警告。所有事務(wù)安全表將被恢復(fù)，但是非事務(wù)安全表將不會(huì)改變。

如果你使用 START TRANSACTION 或 SET AUTOCOMMIT=0，你應(yīng)該使用 MySQL

二進(jìn)制日志做備份以代替老的更新日志。事務(wù)處理被以一個(gè)大塊形式存儲(chǔ)在二進(jìn)制日志中，在 COMMIT

上面，為了保護(hù)回滾的事務(wù)，而不是被存儲(chǔ)的。查看章節(jié) 4.9.4 二進(jìn)制日志。 如果您使用起動(dòng)事務(wù)處理或集AUTOCOMMIT=0

，您應(yīng)該使用MySQL 二進(jìn)制日志為備份代替更舊的更新日志。 事務(wù)處理存儲(chǔ)在二進(jìn)制登錄一大塊，做，保證, 滾的事務(wù)處理不存儲(chǔ)。 參見(jiàn)部分4

。9.4 二進(jìn)制日志。

下列命令自動(dòng)的結(jié)束一個(gè)事務(wù) (就好像你在執(zhí)行這個(gè)命令之前，做了一個(gè) COMMIT)：

命令 命令 命令

ALTER TABLE BEGIN CREATE INDEX

DROP DATABASE DROP TABLE RENAME TABLE

TRUNCATE

你可以使用 SET TRANSACTION ISOLATION LEVEL ... 改變事務(wù)的隔離級(jí)。查看章節(jié) 6.7.3 SET TRANSACTION 句法。

6.7.2 LOCK TABLES/UNLOCK TABLES 句法

LOCK TABLES tbl_name [AS alias] {READ [LOCAL] | [LOW_PRIORITY] WRITE}

[, tbl_name [AS alias] {READ [LOCAL] | [LOW_PRIORITY] WRITE} ...]

...

UNLOCK TABLES

LOCK TABLES 為當(dāng)前線程鎖定表。UNLOCK TABLES 釋放當(dāng)前線程擁有的所有鎖定。當(dāng)線程發(fā)出另一個(gè) LOCK TABLES，或當(dāng)與服務(wù)器的連接被關(guān)閉時(shí)，被當(dāng)前線程鎖定的所有表將被自動(dòng)地解鎖。

為了在 MySQL 4.0.2 使用 LOCK TABLES ，你必須擁有一個(gè)全局的 LOCK TABLES 權(quán)限和一個(gè)在相關(guān)表上的

SELECT 權(quán)限。在 MySQL 3.23 中，你對(duì)該表需要有 SELECT、insert、DELETE 和 UPDATE 權(quán)限。

使用 LOCK TABLES 的主要原因是，仿效事務(wù)處理或在更新表時(shí)得到更快的速度。此后會(huì)有更詳細(xì)的描述。

如果一個(gè)線程在一個(gè)表上得到一個(gè) READ 鎖，該線程 (和所有其它線程) 只能從表中讀取。如果一個(gè)線程在一個(gè)表上得到一個(gè) WRITE 鎖，那么只有擁有這個(gè)鎖的線程可以從表中讀取和寫(xiě)表。其它的線程被阻塞。

READ LOCAL 和 READ 之間的不同就在于，當(dāng)鎖被加載時(shí)，READ LOCAL 允許非沖突(non-conflicting) INSERT 語(yǔ)句執(zhí)行。如果當(dāng)你加載著鎖時(shí)從 MySQL 外部操作數(shù)據(jù)庫(kù)文件，這將仍不能被使用。

當(dāng)你使用 LOCK TABLES 是地，你必須鎖定所有你將使用的表，并且必須使用與你的查詢中將使用的別名相同！如果你在一個(gè)查詢中多次使用一個(gè)表(用別名)，你必須為每一個(gè)別名獲得一個(gè)鎖。

WRITE 鎖通過(guò)比 READ 鎖有更高的權(quán)限，以確保更新被盡快地處理。這就意味著，如果一個(gè)線程獲得一個(gè) READ

鎖，而同時(shí)另外一個(gè)線程請(qǐng)求一個(gè) WRITE 鎖，并發(fā)的 READ 鎖請(qǐng)求將等待直到 WRITE 線程得到了鎖并釋放了它。你可以使用

LOW_PRIORITY WRITE 鎖，當(dāng)該線程在等待 WRITE 鎖時(shí)，它將允許其它的線程獲得 READ 鎖。 你應(yīng)該只使用

LOW_PRIORITY WRITE 鎖，如果你確信這將是最后一次，當(dāng)沒(méi)有線程將擁有 READ 鎖。

LOCK TABLES 工作如下：

以內(nèi)部定義的次序排序所有被鎖定的表 (從用戶立場(chǎng)說(shuō)，該次序是不明確的)。

如果一個(gè)表被以一個(gè)讀鎖和一個(gè)寫(xiě)鎖鎖定，將寫(xiě)鎖放在讀鎖之前。

一次只鎖定一個(gè)表，只到線程得到所有的鎖定。

這個(gè)方案是為了確保，表鎖定死鎖釋放。 對(duì)于這個(gè)模式你仍然有些其它事情需要知道：

如果你對(duì)一個(gè)表使用一個(gè) LOW_PRIORITY WRITE 鎖定，這就意味著，MySQL 將等待這個(gè)鎖，直到?jīng)]有線程請(qǐng)求一個(gè) READ

鎖。當(dāng)線程得到了 WRITE 鎖，并等待獲得鎖定表列表中的下一個(gè)表的鎖定時(shí)，其它所有的線程將等待 WRITE

鎖被釋放。如果這在你的應(yīng)用程序中會(huì)引起一個(gè)嚴(yán)重的問(wèn)題，你應(yīng)該考慮將你的某些表轉(zhuǎn)換為事務(wù)安全表。

你可以使用 KILL 安全地殺死一個(gè)正在表鎖定的線程。查看章節(jié) 4.5.5 KILL 句法。

注意，你不應(yīng)該 鎖定你正在對(duì)其使用 INSERT DELAYED 的表。這是因?yàn)?，在這種情況下，INSERT 是通過(guò)單獨(dú)的線程完成的。

通常，你不需要鎖定任何表，因?yàn)樗袉?UPDATE 語(yǔ)句都是原子的；其它的線程無(wú)法干擾當(dāng)前執(zhí)行的 SQL 語(yǔ)句。當(dāng)你無(wú)論如何希望鎖定表時(shí)，這里有一些情況：

如果你在一束表上運(yùn)行許多操作，鎖定你將要使用的表，這會(huì)更快一些。當(dāng)然有不利的方面，其它線程將不能更新一個(gè) READ

鎖的表，并且沒(méi)有其它線程要以讀取一個(gè) WRITE 鎖的表。 在 LOCK TABLES 下，某些事運(yùn)行得更快一些的原因是，MySQL

將不會(huì)轉(zhuǎn)儲(chǔ)清除被鎖定表鍵高速緩沖，直到 UNLOCK TABLES 被調(diào)用 (通常鍵高速緩沖在每個(gè) SQL 語(yǔ)句后都會(huì)被轉(zhuǎn)儲(chǔ)清除)。這將加速在

MyISAM 表上的插入、更新、刪除。

如果你在 MySQL 中正在使用一個(gè)不支持事務(wù)的存儲(chǔ)引擎，如果你希望能確保沒(méi)有其它的線程會(huì)出現(xiàn)在一個(gè) SELECT 和 一個(gè) UPDATE 之間，你必須使用 LOCK TABLES 。下面的示例顯示為了安全地執(zhí)行，這里需要LOCK TABLES ：

mysql LOCK TABLES trans READ, customer WRITE;

mysql SELECT SUM(value) FROM trans WHERE customer_id=some_id;

mysql UPDATE customer SET total_value=sum_from_previous_statement

- WHERE customer_id=some_id;

mysql UNLOCK TABLES;

不使用 LOCK TABLES，將可能發(fā)生在 SELECT 和 UPDATE 語(yǔ)句執(zhí)行期間有另外一個(gè)線程可能在 trans 表中插入一行新記錄。

通過(guò)使用遞增更新 (UPDATE customer SET value=value+new_value) 或 LAST_INSERT_ID() 函數(shù)，你可以在很多情況下避免使用 LOCK TABLES。

你也可以使用用戶級(jí)鎖定函數(shù) GET_LOCK() 和 RELEASE_LOCK() 解決一些情況，這些鎖被保存在服務(wù)器上的一個(gè)哈希表中，并以

pthread_mutex_lock() 和 pthread_mutex_unlock() 實(shí)現(xiàn)以獲得高速度。查看章節(jié) 6.3.6.2

輔助功能函數(shù)。

查看章節(jié) 5.3.1 MySQL 如何鎖定表，以獲取關(guān)于鎖定方案的更多信息。

你可以使用 FLUSH TABLES WITH READ LOCK 命令以讀鎖鎖定所有數(shù)據(jù)庫(kù)中的所有表。查看章節(jié) 4.5.3 FLUSH 句法。如果你有一個(gè)可以及時(shí)建立文件快照的文件系統(tǒng)，例如 Veritas，這將是得到備份的非常方便方式。

注意：LOCK TABLES 不是事務(wù)安全的，在嘗試鎖定一個(gè)表之前，將自動(dòng)地提交所有的活動(dòng)事務(wù)。

6.7.3 SET TRANSACTION 句法

SET [GLOBAL | SESSION] TRANSACTION ISOLATION LEVEL

{ READ UNCOMMITTED | READ COMMITTED | REPEATABLE READ | SERIALIZABLE }

設(shè)置全局的、整個(gè)會(huì)話或下一個(gè)事務(wù)的事務(wù)隔離級(jí)。

缺省行為是設(shè)置下一個(gè)(未啟動(dòng)的)事務(wù)的隔離級(jí)。如果你使用 GLOBAL

關(guān)鍵詞，語(yǔ)句為所有在那個(gè)點(diǎn)上建立的新連接設(shè)置默認(rèn)的全局事務(wù)隔離級(jí)。為了這樣做，你需要有 SUPER 權(quán)限。使用 SESSION

關(guān)鍵詞為當(dāng)前連接所有將來(lái)執(zhí)行的事務(wù)設(shè)置默認(rèn)的事務(wù)隔離級(jí)。

你可以使用 --transaction-isolation=... 為 mysqld 設(shè)置默認(rèn)的全局隔離級(jí)。查看章節(jié) 4.1.1 mysqld 命令行選項(xiàng)

Mysql數(shù)據(jù)庫(kù)中，事務(wù)是指什么？如何使用該功能？

什么是事務(wù)？ \x0d\x0a\x0d\x0a事務(wù)是邏輯上的一組操作，組成這組操作的各個(gè)單元，要不全都成功要不全都失敗，這個(gè)特性就是事務(wù) \x0d\x0a\x0d\x0a注意：mysql數(shù)據(jù)支持事務(wù)，但是要求必須是innoDB存儲(chǔ)引擎 \x0d\x0a\x0d\x0a解決這個(gè)問(wèn)題： \x0d\x0a\x0d\x0amysql的事務(wù)解決這個(gè)問(wèn)題，因?yàn)閙ysql的事務(wù)特性，要求這組操作，要不全都成功，要不全都失敗，這樣就避免了某個(gè)操作成功某個(gè)操作失敗。利于數(shù)據(jù)的安全 \x0d\x0a\x0d\x0a如何使用： \x0d\x0a\x0d\x0a（1）在執(zhí)行sql語(yǔ)句之前，我們要開(kāi)啟事務(wù) start transaction; \x0d\x0a\x0d\x0a（2）正常執(zhí)行我們的sql語(yǔ)句 \x0d\x0a\x0d\x0a（3）當(dāng)sql語(yǔ)句執(zhí)行完畢，存在兩種情況： \x0d\x0a\x0d\x0a1，全都成功，我們要將sql語(yǔ)句對(duì)數(shù)據(jù)庫(kù)造成的影響提交到數(shù)據(jù)庫(kù)中，committ \x0d\x0a\x0d\x0a2，某些sql語(yǔ)句失敗，我們執(zhí)行rollback（回滾），將對(duì)數(shù)據(jù)庫(kù)操作趕緊撤銷(xiāo) \x0d\x0a\x0d\x0a（注意：mysql數(shù)據(jù)支持事務(wù)，但是要求必須是innoDB存儲(chǔ)引擎） \x0d\x0amysql create table bank(name varchar(20),money decimal(5,1))engine=innodb defau \x0d\x0alt charset=utf8; \x0d\x0a\x0d\x0amysql inset into bank values('shaotuo',1000),('laohu',5000); \x0d\x0a\x0d\x0amysql select*from bank; \x0d\x0a+---------+--------+ \x0d\x0a| name | money | \x0d\x0a+---------+--------+ \x0d\x0a| shaotuo | 1000.0 | \x0d\x0a| laohu | 5000.0 | \x0d\x0a+---------+--------+ \x0d\x0a\x0d\x0a------沒(méi)有成功“回滾”執(zhí)行rollback \x0d\x0amysql start transaction; //開(kāi)啟事務(wù) \x0d\x0aQuery OK, 0 rows affected (0.00 sec) \x0d\x0a\x0d\x0amysql update bank set money=money+500 where name='shaotuo'; \x0d\x0aQuery OK, 1 row affected (0.00 sec) \x0d\x0aRows matched: 1 Changed: 1 Warnings: 0 \x0d\x0a\x0d\x0amysql update bank set moey=money-500 where name='laohu'; \x0d\x0aERROR 1054 (42S22): Unknown column 'moey' in 'field list' \x0d\x0amysql rollback; //只要有一個(gè)不成功，執(zhí)行rollback操作 \x0d\x0aQuery OK, 0 rows affected (0.01 sec) \x0d\x0a\x0d\x0amysql select*from bank; \x0d\x0a+---------+--------+ \x0d\x0a| name | money | \x0d\x0a+---------+--------+ \x0d\x0a| shaotuo | 1000.0 | \x0d\x0a| laohu | 5000.0 | \x0d\x0a+---------+--------+ \x0d\x0a------成功之后 進(jìn)行commit操作 \x0d\x0amysql start transaction; //開(kāi)啟事務(wù) \x0d\x0aQuery OK, 0 rows affected (0.00 sec) \x0d\x0a\x0d\x0amysql update bank set money=money+500 where name='shaotuo'; \x0d\x0aQuery OK, 1 row affected (0.01 sec) \x0d\x0aRows matched: 1 Changed: 1 Warnings: 0 \x0d\x0a\x0d\x0amysql update bank set money=money-500 where name='laohu'; \x0d\x0aQuery OK, 1 row affected (0.00 sec) \x0d\x0aRows matched: 1 Changed: 1 Warnings: 0 \x0d\x0a\x0d\x0amysql commit; //兩個(gè)都成功后執(zhí)行commit（只要不執(zhí)行commit，sql語(yǔ)句不會(huì)對(duì)真實(shí)的數(shù)據(jù)庫(kù)造成影響） \x0d\x0aQuery OK, 0 rows affected (0.05 sec) \x0d\x0a\x0d\x0amysql select*from bank; \x0d\x0a+---------+--------+ \x0d\x0a| name | money | \x0d\x0a+---------+--------+ \x0d\x0a| shaotuo | 1500.0 | \x0d\x0a| laohu | 4500.0 | \x0d\x0a+---------+--------+

MYSQL5.5中如何使用事務(wù)？

首先一點(diǎn), 如果你是 mysql 5.5 肯定支持事務(wù)

其次, 是否可以用事務(wù), 取決于你使用的表的存儲(chǔ)引擎.

默認(rèn) myIsam 是不支持事務(wù)的

你要把表轉(zhuǎn)換成 Innodb 存儲(chǔ)引擎才可以使用事務(wù)

你怎么知道你的不支持呢，

你來(lái)做個(gè)試驗(yàn)好了。

打開(kāi)是事務(wù)請(qǐng)鍵入：

set @@AUTOCOMMIT=0;

BEGIN WORK;

然后你去把你MySQL的某一張表中的數(shù)據(jù)刪除

然后再打:ROLLBACK WORK;

你就驚訝的發(fā)現(xiàn)，你剛才刪的數(shù)據(jù)還原了

回滾事物：SAVEPOINT id

id是保存點(diǎn)的名稱(chēng)

結(jié)束事物：COMMIT

具體還是要一本書(shū)才行。網(wǎng)絡(luò)上的其實(shí)說(shuō)實(shí)話太雜了

最后補(bǔ)充一下, 修改存儲(chǔ)引擎的 MYSQL 語(yǔ)句:

alter table 表名 type = InnoDB;

在多文件上傳中如何用mysql開(kāi)啟事務(wù)

看你是什么事務(wù)，jdbc事務(wù)，還是分布式事務(wù)，還是容器事務(wù)

1，編程式事務(wù)管理（jdbc的事務(wù)是綁定在connection上的）

Connection conn = null;

try

{

Class.forName("com.mysql.jdbc.Driver");

conn = DriverManager.getConnection("jdbc:oracle:thin:@host:1521:SID","username","password");

conn.setAutoCommit(false); //取消自動(dòng)提交

PreparedStatement ps = conn.prepareCall("update something");

ResultSet rs = ps.executeQuery();

conn.commit(); //手動(dòng)提交

}

catch (Exception e)

{

conn.rollback();

e.printStackTrace();

}

finally

{

conn.close();

}

2，聲明式事務(wù)

先在工程的application.xml配置文件中添加如下代碼，開(kāi)啟事務(wù)

!-- 聲明式事務(wù)控制配置 --

tx:annotation-driven transaction-manager="txManager"/

bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"

property name="datasource" ref="bassDataSource"/property

/bean

然后在你需要開(kāi)啟事務(wù)的接口前面添加注解

@Transactional(rollbackFor = IOException.class)

public void add(String name) throws IOException

{

System.out.println("可以再類(lèi)里和方法里面添加事務(wù)注解0~0");

throw new IOException();

}

直接調(diào)用接口方法就好

分布式事務(wù)處理（mysql貌似在5.X之后才支持） 的話，

1.可以直接使用spring+atomikos框架進(jìn)行管理

參考：

就不貼測(cè)試代碼了，自己看著配置吧

2，使用JTA（Java Transaction API）進(jìn)行分布式事務(wù)管理（測(cè)試代碼如下）

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.SQLException;

import javax.naming.InitialContext;

import javax.sql.DataSource;

import javax.transaction.SystemException;

import javax.transaction.UserTransaction;

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;

//分布式事務(wù)處理

public class transferAccount

{

@SuppressWarnings("null")

public void testTransferAccount()

{

UserTransaction userts = null;

Connection connA = null;

PreparedStatement psA = null;

InitialContext context = null;

Connection connB = null;

PreparedStatement psB = null;

try

{

//獲得事務(wù)管理對(duì)象

userts = (UserTransaction) context.lookup("java:comp/UserTransaction");

//獲取兩個(gè)數(shù)據(jù)庫(kù)

connA = getDataSourceA().getConnection();

connB = getDataSourceB().getConnection();

//開(kāi)啟事務(wù)

userts.begin();

//sql語(yǔ)句

psA = connA.prepareStatement("我加1");

psB = connB.prepareStatement("我減1");

//執(zhí)行sql

psA.executeUpdate();

psB.executeUpdate();

//事務(wù)提交

userts.commit();

} catch (Exception e)

{

try

{

userts.rollback();

} catch (IllegalStateException | SecurityException

| SystemException e1)

{

e1.printStackTrace();

}

e.printStackTrace();

}

finally

{

try

{

psA.close();

psB.close();

connA.close();

connB.close();

} catch (SQLException e)

{

e.printStackTrace();

}

}

}

public DataSource getDataSourceA()

{

MysqlDataSource dataSource = new MysqlDataSource();

dataSource.setDatabaseName("mysql");

dataSource.setServerName("server");

dataSource.setPortNumber(1433);

dataSource.setUser("test");

dataSource.setPassword("test");

return dataSource;

}

public DataSource getDataSourceB()

{

MysqlDataSource dataSource = new MysqlDataSource();

dataSource.setDatabaseName("mysql");

dataSource.setServerName("server");

dataSource.setPortNumber(1435);

dataSource.setUser("test1");

dataSource.setPassword("test1");

return dataSource;

}

}

Mysql中的事務(wù)是什么如何使用

事務(wù)能保證用戶做的一系列動(dòng)作，要么全部成功。如果有一個(gè)操作失敗，就回退到修改前。 比如你要做下面幾個(gè)操作，

1、刪除表A中的某些記錄

2、向B添加一些記錄。

3、修改C表中的一些數(shù)據(jù)。

使用事務(wù)，如果1,2都成功了，3卻失敗了。就會(huì)回退到第1步執(zhí)行前的樣子，ABC表都沒(méi)被修改。

新聞名稱(chēng)：mysql中事務(wù)怎么用 mysql如何支持事務(wù)
分享網(wǎng)址：http://aaarwkj.com/article40/docpgeo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供域名注冊(cè)、App開(kāi)發(fā)、服務(wù)器托管、網(wǎng)站維護(hù)、網(wǎng)站策劃、云服務(wù)器

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)