怎么给mysql添加事务 mysql事务注意什么

如何开启mysql的事务支持

看你是什么事务，jdbc事务，还是分布式事务，还是容器事务

创新互联公司服务项目包括古县网站建设、古县网站制作、古县网页制作以及古县网络营销策划等。多年来，我们专注于互联网行业，利用自身积累的技术优势、行业经验、深度合作伙伴关系等，向广大中小型企业、政府机构等提供互联网行业的解决方案，古县网站推广取得了明显的社会效益与经济效益。目前，我们服务的客户以成都为中心已经辐射到古县省份的部分城市，未来相信会继续扩大服务区域并继续获得客户的支持与信任！

1，编程式事务管理（jdbc的事务是绑定在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); //取消自动提交

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

ResultSet rs = ps.executeQuery();

conn.commit(); //手动提交

}

catch (Exception e)

{

conn.rollback();

e.printStackTrace();

}

finally

{

conn.close();

}

2，声明式事务

先在工程的application.xml配置文件中添加如下代码，开启事务

!-- 声明式事务控制配置 --

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

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

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

/bean

然后在你需要开启事务的接口前面添加注解

@Transactional(rollbackFor = IOException.class)

public void add(String name) throws IOException

{

System.out.println("可以再类里和方法里面添加事务注解0~0");

throw new IOException();

}

直接调用接口方法就好

分布式事务处理（mysql貌似在5.X之后才支持） 的话，

1.可以直接使用spring+atomikos框架进行管理

参考：

就不贴测试代码了，自己看着配置吧

2，使用JTA（Java Transaction API）进行分布式事务管理（测试代码如下）

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;

//分布式事务处理

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

{

//获得事务管理对象

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

//获取两个数据库

connA = getDataSourceA().getConnection();

connB = getDataSourceB().getConnection();

//开启事务

userts.begin();

//sql语句

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

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

//执行sql

psA.executeUpdate();

psB.executeUpdate();

//事务提交

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 存储过程怎么设置事务

CREATE DEFINER=`root`@`localhost` PROCEDURE `createBusiness`(parameter1 int)

BEGIN

#Routine body goes here...

DECLARE flag int DEFAULT parameter1;#声明变量flag，将参数值赋给该变量

DECLARE uuidStr VARCHAR(32);#声明一个长度为32位的字符串

DECLARE currentTime TIMESTAMP;#声明一个类型为时间戳的变量

declare err INT default 0;#声明一个整形变量err，默认值是0

declare continue handler for sqlexception set err=1;#当sqlexception handler捕捉到异常时，设置err=1

START TRANSACTION;#开始事务

WHILE flag0 DO #注意: while不能空实现(在while块中，里面必须有语句)

#uuid()函数得到的字符串是'6ccd780c-baba-1026-9564-0040f4311e29'，剔除里面的-，得到一个32位的字符串

SET uuidStr = REPLACE(UUID(),'-','') ;

#得到当前的时间

SET currentTime = CURRENT_TIMESTAMP();

#执行插入语句，注意连接字符串的函数concat(str1,str2,...);其中str..也可以是数字类型

INSERT INTO

表名称

(id,title,keyword,hasImage,isTodayHead,isShowInHome,isBigness,publishTime,originId,modify_time,isAnalysis)

VALUE

(uuidStr,CONCAT('事件标题',flag),CONCAT('关键字',flag),1,1,0,0,currentTime,CONCAT('xxxxxxx',flag),currentTime,1);

#每循环一次，flag要减去1，注意没有flag--的语法

set flag = flag-1;

#在这里测试当err=1时，事务是否有了回滚，测试ok

#IF flag=7 THEN #注意在procedure中给变量赋值要用到set,或在变量声明时用default来父子，所以=号可以用来比较两边的值是否相等，=也可，区别先不去纠结。

#set err=1;

#END if;

END WHILE;

IF (err=0) THEN

commit;

select 'OK';

ELSE

rollback;

select 'err';

END IF;

END;

navicat怎么开启事务？navicate如何在mysql的定时事务开启啊？

1、启动Navicat for MySQL，新建数据库连接，打开数据库，可能有点啰嗦。

2、可以先查看定时任务的是否开启。通过以下命令：show variables like '%sche%';

3、如果其设置值为为 OFF 或 0 ，通过执行下列语句，来开启event_scheduler，set global event_scheduler =1，把设置为设为ON 或 1。

4、新建一个函数 ，取名为update_qiandao ,内容为 UPDATE week7_user SET isqiandao = 0

5、参照上图，新建一个事件 ，在定义里写 call update_qiandao() --也就是之前定义的函数

在“计划”选项卡中设置 执行时间，这里我选择的是每天。