如何用java开启mysql事务，要求详细

如何用java开启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框架进行管理

参考：http://blog.chinaunix.net/uid-21162795-id-3424973.html

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

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

}

}

下面代码是使用jdbc直接链接mysql的 *** 作，链接方式与SQL SERVER类似，区别在于加载的驱动不同，url的设置也有点区别，用户名、密码、端口号这些设置都类似

执行脚本返回的结果，可以看出java成功链接上mysql并获取到返回值

mysql-connector-java-5.1.26-bin.jar是java链接mysql使用的jar包，与SQL SERVER链接也有专门的jar包，jar包中包含了java链接mysql所用到的函数驱动等等，所有的jar包都是放到web工程lib目录下

如果工程是整合在ssh下，一般情况下都会有一个properties文件，该文件配置了数据库链接常用的命令，下图是mysql中的配置

使用spring框架下进行的测试，结果可以成功执行，其实无论是sql server还是mysql还是其他的数据库，基本功能都一样，只是语法结构有所区别，java在调用的过程中大部分功能只要切换了数据库链接命令就可以公用，如果系统架构设计的足够好，当我们切换数据库的时候，应用程序是不用调整就能兼容的

你的意思，java不直接hibernate而是cmd用高级语言调用低级语言再 *** 作数据库数据库是吗？这个想法~~~这个需求是干什么的，那些代码又在来完成，如果是本季，那我给出来的命令足够你用，如果在服务器上，那你怎么看java的跨平台行，cmd不是所有系统都可以的，除非你认为跨平台没用，那么你就不该选择java ，c和汇编，甚至性0，1更适合你

连接：mysql -h主机地址 -u用户名 －p用户密码 （注:u与root可以不用加空格，其它也一样）

断开：exit （回车）

创建授权：grant select on 数据库.* to 用户名@登录主机 identified by \"密码\"

修改密码：mysqladmin -u用户名 -p旧密码 password 新密码

删除授权: revoke select,insert,update,delete om *.* from test2@localhost

显示数据库：show databases

显示数据表：show tables

显示表结构：describe 表名

创建库：create database 库名

删除库：drop database 库名

使用库：use 库名

创建表：create table 表名 (字段设定列表)

删除表：drop table 表名

修改表：alter table t1 rename t2

查询表：select * from 表名

清空表：delete from 表名

备份表: mysqlbinmysqldump -h(ip) -uroot -p(password) databasename tablename >tablename.sql

恢复表: mysqlbinmysql -h(ip) -uroot -p(password) databasename tablename <tablename.sql（ *** 作前先把原来表删除）

增加列：ALTER TABLE t2 ADD c INT UNSIGNED NOT NULL AUTO_INCREMENT,ADD INDEX (c)

修改列：ALTER TABLE t2 MODIFY a TINYINT NOT NULL, CHANGE b c CHAR(20)

删除列：ALTER TABLE t2 DROP COLUMN c

备份数据库：mysql\bin\mysqldump -h(ip) -uroot -p(password) databasename >database.sql

恢复数据库：mysql\bin\mysql -h(ip) -uroot -p(password) databasename <database.sql

复制数据库：mysql\bin\mysqldump --all-databases >all-databases.sql

修复数据库：mysqlcheck -A -o -uroot -p54safer

文本数据导入： load data local infile \"文件名\" into table 表名

数据导入导出：mysql\bin\mysqlimport database tables.txt

---