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
}
}
Statement换成preparedStatement，就有相应的set方法了。
或者既然addBatch里面传入的是String类型，那我们自己构造，
stmt.addBatch(“insert into users values ("+"values1"+","+"values2"+")")
或者既然是users类，我们可以根据users中属性是否为初始值来自动生成inset语句，下面是我以前写的代码，仅供参考
注释：
1、下面的User.NAME等就是user中name属性在表中的列名
2、方法ConvertStr就是把插入的列的value加上单引号。
private static String ConvertStr(Object object) {
return "'" + object.toString() + "'"
}
3、其他
public static final String strIns = "insert into users("
public static final String strVal = ") values("
public static final String strEnd = ")"
4、调用
stmt.addBatch(User.InsetStr(user))//这样就不用考虑传参了
代码如下：
public static String InsetStr(User user) {String StrCol = ""
String Values = ""
if (user.getName() != null &&!user.getName().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.NAME
Values = Values + "," + ConvertStr(user.getName())
} else {
StrCol = StrCol + User.NAME
Values = Values + ConvertStr(user.getName())
}
}
if (user.getNick() != null &&!user.getNick().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.NICK
Values = Values + "," + ConvertStr(user.getNick())
} else {
StrCol = StrCol + User.NICK
Values = Values + ConvertStr(user.getNick())
}
}
if (user.getStudentid() != 0) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.STUDENTID
Values = Values + "," + ConvertStr(user.getStudentid())
} else {
StrCol = StrCol + User.STUDENTID
Values = Values + ConvertStr(user.getStudentid())
}
}
if (user.getSex() != '\u0000') {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.SEX
Values = Values + "," + ConvertStr(user.getSex())
} else {
StrCol = StrCol + User.SEX
Values = Values + ConvertStr(user.getSex())
}
}
if (user.getPassword() != null &&!user.getPassword().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.PASSWORD
Values = Values + "," + ConvertStr(user.getPassword())
} else {
StrCol = StrCol + User.PASSWORD
Values = Values + ConvertStr(user.getPassword())
}
}
if (user.getHash() != null &&!user.getHash().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.HASH
Values = Values + "," + ConvertStr(user.getHash())
} else {
StrCol = StrCol + User.HASH
Values = Values + ConvertStr(user.getHash())
}
}
if (user.getSchool() != null &&!user.getSchool().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.SCHOOL
Values = Values + "," + ConvertStr(user.getSchool())
} else {
StrCol = StrCol + User.SCHOOL
Values = Values + ConvertStr(user.getSchool())
}
}
if (user.getMajor() != null &&!user.getMajor().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.MAJOR
Values = Values + "," + ConvertStr(user.getMajor())
} else {
StrCol = StrCol + User.MAJOR
Values = Values + ConvertStr(user.getMajor())
}
}
if (user.getMobile() != 0) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.MOBILE
Values = Values + "," + ConvertStr(user.getMobile())
} else {
StrCol = StrCol + User.MOBILE
Values = Values + ConvertStr(user.getMobile())
}
}
if (user.getCollege() != null &&!user.getCollege().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.COLLEGE
Values = Values + "," + ConvertStr(user.getCollege())
} else {
StrCol = StrCol + User.COLLEGE
Values = Values + ConvertStr(user.getCollege())
}
}
if (user.getGrade() != 0) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.GRADE
Values = Values + "," + ConvertStr(user.getGrade())
} else {
StrCol = StrCol + User.GRADE
Values = Values + ConvertStr(user.getGrade())
}
}
if (user.getBclass() != null &&!user.getBclass().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.BCLASS
Values = Values + "," + ConvertStr(user.getBclass())
} else {
StrCol = StrCol + User.BCLASS
Values = Values + ConvertStr(user.getBclass())
}
}
if (user.getIdnum() != null &&!user.getIdnum().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.IDNUM
Values = Values + "," + ConvertStr(user.getIdnum())
} else {
StrCol = StrCol + User.IDNUM
Values = Values + ConvertStr(user.getIdnum())
}
}
if (user.getEmail() != null &&!user.getEmail().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.EMAIL
Values = Values + "," + ConvertStr(user.getEmail())
} else {
StrCol = StrCol + User.EMAIL
Values = Values + ConvertStr(user.getEmail())
}
}
if (user.getRegip() != null &&!user.getRegip().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.REGIP
Values = Values + "," + ConvertStr(user.getRegip())
} else {
StrCol = StrCol + User.REGIP
Values = Values + ConvertStr(user.getRegip())
}
}
if (user.getRegdate() != 0) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.REGDATE
Values = Values + "," + ConvertStr(user.getRegdate())
} else {
StrCol = StrCol + User.REGDATE
Values = Values + ConvertStr(user.getRegdate())
}
}
if (user.getUnit() != null &&!user.getUnit().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.UNIT
Values = Values + "," + ConvertStr(user.getUnit())
} else {
StrCol = StrCol + User.UNIT
Values = Values + ConvertStr(user.getUnit())
}
}
if (user.getRegion() != null &&!user.getRegion().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.REGION
Values = Values + "," + ConvertStr(user.getRegion())
} else {
StrCol = StrCol + User.REGION
Values = Values + ConvertStr(user.getRegion())
}
}
if (user.getDepartments() != null &&!user.getDepartments().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.DEPARTMENTS
Values = Values + "," + ConvertStr(user.getDepartments())
} else {
StrCol = StrCol + User.DEPARTMENTS
Values = Values + ConvertStr(user.getDepartments())
}
}
if (user.getTdcj() >0) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.TDCJ
Values = Values + "," + ConvertStr(user.getTdcj())
} else {
StrCol = StrCol + User.TDCJ
Values = Values + ConvertStr(user.getTdcj())
}
}
if (user.getTzcj() >0) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.TZCJ
Values = Values + "," + ConvertStr(user.getTzcj())
} else {
StrCol = StrCol + User.TZCJ
Values = Values + ConvertStr(user.getTzcj())
}
}
if (user.getAddress() != null &&!user.getAddress().equals("")) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.ADDRESS
Values = Values + "," + ConvertStr(user.getAddress())
} else {
StrCol = StrCol + User.ADDRESS
Values = Values + ConvertStr(user.getAddress())
}
}
if (user.getPostcode() != 0) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.POSTCODE
Values = Values + "," + ConvertStr(user.getPostcode())
} else {
StrCol = StrCol + User.POSTCODE
Values = Values + ConvertStr(user.getPostcode())
}
}
if (user.getBankcard() != 0) {
if (!StrCol.equals("")) {
StrCol = StrCol + "," + User.BANKCARD
Values = Values + "," + ConvertStr(user.getBankcard())
} else {
StrCol = StrCol + User.BANKCARD
Values = Values + ConvertStr(user.getBankcard())
}
}
return Sql.strIns + StrCol + Sql.strVal + Values + Sql.strEnd
}
【导读】作为大数据工程师，其必须要掌握的基础知识就是java与mysql的关系、交互和连接，作为基础，也是面试考官经常会考的内容，为了帮助大家都能顺利通过考试，今天小编就来和大家唠一唠java与mysql的关系、交互和连接，好了，开始今天的内容大数据分析师面试必备：java与mysql解析。
1. SQL语言四大类：
DQL 数据查询语言 select
DML 数据 *** 作语言 insert、update、delete
DDL 数据界说语言 create、alter
DCL 数据控制语言 grant权限
2. mysql数据库中的decimal类型(是数值型，不能存放字符串)：
举例：decimal(18,0) 常用于身份z号码，但是带x的不可以。
举例：decimal(5,2)
状况一：假设小数点前面是3位，后边是2位，正常状况。
状况二：5指的是小数点前后不能超过5位，小数点后有必要是2位。
3. mysql中InnoDB和MyISAM引擎的差异：
innodb支撑：事务和主外键
myisam不支撑：事务和主外键
4. 【不需要背诵，选择题考点】向mysql中，a向表中添加数据的几种写法，题目：id int 主键自增，name varchar(11)
不为空。
5. *** 作mysql数据库表有两种方式，第一种：点八点吧第二种：写代码。【不需要背诵，只需要了解，考试选择题会出】
6. 在Java中，简述面向对象三大特征。
7. 在Java中，常用关键字：
1. 定义类的关键字是什么? class
2. 继承的关键字是什么? extends
3. 定义接口的关键字是什么? interface
4. 实现接口的关键字是什么? implements
5. 抽象类的关键字是什么? abstract
8. 在Java中，抽象类和接口的区别：
1. 抽象类中可以包含普通方法和抽象方法，接口中只能包含抽象方法
2. 抽象类中可以有构造方法，接口中没有构造方法
3. 抽象类只能单继承，可以实现多个接口
9. Java接口中有哪些成员?
1. 构造方法，没有
2. 常量，默认访问修饰符public static final，没有变量
3. 抽象方法，默认访问修饰符public abstract
10. 在Java中，抽象类和抽象方法的关系：
1. 抽象类中可以包含普通方法和抽象方法，抽象方法一定存在抽象类中。
2. 子类继承抽象父类，必须实现|重写抽象方法，除非子类也是抽象类。
3. 【判断题】抽象类中必须包含抽象方法?【错误×】
4. 【判断题】抽象方法一定存在抽象类中?【正确√】
11. Java重载的特点：
1. 在同一个类中
2. 方法名相同
3. 参数列表(个数、类型、顺序)不同
4. 与返回值类型和访问修饰符无关
12. Java重写的特点：
1. 在父子类中
2. 方法名相同
3. 参数列表相同
4. 返回值类型相同，或是其子类
5. 访问修饰符相同，或不能严于父类
13. 列举几种Java实现多态的形式：
1. 继承的存在
2. 父类引用指向子类对象 | 向上转型
3. 父类作为方法的返回值类型，父类作为方法的参数
14. Java接口的特性：单根性和传递性
15. 在Java中，throws和throw的区别：
1. throws 声明异常，用在定义方法小括号的后面
2. throw 抛出异常，写在方法体内
以上就是小编今天给大家整理发送的关于大数据分析师面试必备：java与mysql解析的相关内容，希望对各位考生有所帮助，想知道更多关于数据分析师的基本要求有哪些，关注小编持续更新数据分析师岗位解析。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）