Java 在 jdbcTemplate 或 DataSource 上提交

Commit on jdbcTemplate or DataSource

提问by Akhil

I wanted to do commit and rollback using jdbcTemplate.

我想使用 jdbcTemplate 进行提交和回滚。

My question is based on this thread

我的问题是基于这个线程

How do I commit or rollback, should I do it on jdbcTemplate like

我如何提交或回滚，我应该在 jdbcTemplate 上做

jdbcTemplate.commit();
jdbcTemplate.rollback();

Or there are some other ways to achieve commit and rollback functionality using jdbcTemplate.

或者还有其他一些方法可以使用 jdbcTemplate 实现提交和回滚功能。

回答by Anatoly Deyneka

the easiest way of managing transactions in spring is @Transactional annotation, so your code will look very simple:

在 spring 中管理事务的最简单方法是 @Transactional 注释，因此您的代码看起来非常简单：

@Transactional(rollbackFor = Exception.class)
public void doSomething(...) {
    ...
}

read more: http://docs.spring.io/spring/docs/current/spring-framework-reference/html/transaction.html

阅读更多：http: //docs.spring.io/spring/docs/current/spring-framework-reference/html/transaction.html

回答by dimitrisli

To call commitor rollbackat will set the transactional boundaries programmatically and not declaratively.

以编程方式而不是以声明方式调用commit或rollback随意设置事务边界。

For that reason you have to get hold of the PlatformTransactionManager- inject it that is in your DAO and perform the commit/ rollbackoperation yourself.

出于这个原因，您必须掌握PlatformTransactionManager- 将它注入您的 DAO 中并自己执行commit/rollback操作。

Sample code:

示例代码：

@Autowired private JdbcTemplate jdbcTemplate;
@Autowired private PlatformTransactionManager platformTransactionManager;

 //..

public void daoMethod(params) {
  DefaultTransactionDefinition paramTransactionDefinition = new    DefaultTransactionDefinition();

  TransactionStatus status=platformTransactionManager.getTransaction(paramTransactionDefinition );
try{
  String sqlQuery = "query";
  jdbcTemplate.update(sqlQuery, params);
  platformTransactionManager.commit(status);
}catch (Exception e) {
  platformTransactionManager.rollback(status);
}

Another approach is to get hold of the TransactionTemplate

另一种方法是获取TransactionTemplate

Sample code:

示例代码：

@Autowired private JdbcTemplate jdbcTemplate;
@Autowired private TransactionTemplate transactionTemplate;

//..


//for operations where query does not return like delete
public void daoMethod(params) {
  transactionTemplate.execute(new TransactionCallbackWithoutResult() {
    protected void doInTransactionWithoutResult(TransactionStatus paramTransactionStatus) {
    try{
      String sqlQuery = "query";
      jdbcTemplate.update(query, params);
    }catch (Exception e) {
      paramTransactionStatus.setRollbackOnly();
    }
    }
  });
}

//for operations where query does return like insert
public int daoMethod(params) {
return  transactionTemplate.execute(new TransactionCallback<Integer>() {
  public Integer doInTransaction(TransactionStatus paramTransactionStatus) {
    String sqlQuery = "query";
    Object[] params = params;
    int[] types = myTypes;
    return jdbcTemplate.update(sqlQuery,params,types);
   }
 });
}}

回答by AntJavaDev

if you have configured the spring transaction manager / jdbcTemplate correctly , then you could always use the @Transactional annotations provided by spring in order to define when you want a transaction to be rolled back or not. But even if you have defined a rollback and your jdbc driver or your database do not allow transactions (check TRANSACTION_ISOLATION over JdbcConnection), then spring will log that is using transactions but the database will simply ignore those points.

如果您已正确配置 spring 事务管理器/ jdbcTemplate ，那么您始终可以使用 spring 提供的 @Transactional 注释来定义何时要回滚事务。但是，即使您定义了回滚并且您的 jdbc 驱动程序或您的数据库不允许事务（通过 JdbcConnection 检查 TRANSACTION_ISOLATION），那么 spring 也会记录正在使用事务的日志，但数据库将简单地忽略这些点。

回答by Branislav Lazic

Use @Transactional. But of course, before of that, you will have to create bean definition for DataSourceTransactionManager:

使用@Transactional. 但当然，在此之前，您必须为以下项目创建 bean 定义DataSourceTransactionManager：

// Your DataSource bean definition
@Bean
public DataSource dataSource() {
    ....
}

// Transaction manager bean definition
@Bean
public DataSourceTransactionManager dataSourceTransactionManager(DataSource dataSource) {
    DataSourceTransactionManager dataSourceTransactionManager = new DataSourceTransactionManager();
    dataSourceTransactionManager.setDataSource(dataSource);

    return dataSourceTransactionManager;
}

And then you can use @Transactional. Example of service:

然后你可以使用@Transactional. 服务示例：

@Service
public class MyServiceImpl {

    @Autowired
    private MyDAO myDAO;

    @Transactional
    public void insert(Entity entity) {
       myDAO.insert(entity);
    }
}

回答by hossein hassanpoor

@Configuration
public class ConfigurationApp {
    @Bean
    public DataSource dataSourceJdbc() {
        BasicDataSource dataSource = new BasicDataSource();
        dataSource.setDriverClassName("oracle.jdbc.driver.OracleDriver");
        dataSource.setUrl("jdbc:oracle:thin:@localhost:1521:orcl");
        dataSource.setUsername("hossein");
        dataSource.setPassword("myjava123");
        dataSource.setDefaultAutoCommit(false);
        return dataSource;
    }

    @Bean
    public JdbcTemplate jdbcTemplate() {
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSourceJdbc());
        return jdbcTemplate;
    }

    @Bean
    public DAOImpl dao() {
        DAOImpl personDAO = new DAOImpl();
        personDAO.setJdbcTemplate(jdbcTemplate());
        return personDAO;
    }


    @Bean
    public PersonService personService() {
        PersonService personService = new PersonService();
        personService.setPersonDAO(dao());
        return personService;
    }
}

//////////////////////////////////////////
public class Person {
    private Integer id;
    private String name;
    private String family;
    private Integer password;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getFamily() {
        return family;
    }

    public void setFamily(String family) {
        this.family = family;
    }

    public Integer getPassword() {
        return password;
    }

    public void setPassword(Integer password) {
        this.password = password;
    }
}
/////////////////////////////////////////
import org.apache.commons.dbcp2.BasicDataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
import java.util.List;

@Repository
public class DAOImpl  {
    private JdbcTemplate jdbcTemplate;

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }


    public int add(Person person) {
        String sql = "insert into person(id,name,family,password) values(?,?,?,?)";
        return this.jdbcTemplate.update(sql, person.getId(), person.getName(), person.getFamily(), person.getPassword());
    }

    public void commit(){
        BasicDataSource basicDataSource= (BasicDataSource) jdbcTemplate.getDataSource();
        basicDataSource.setDefaultAutoCommit(true);
    }
  }

///////////////////////////////////
import org.springframework.stereotype.Service;

import java.util.List;
@Service
public class PersonService {
    private DAOImpl personDAO;
    public void setPersonDAO(DAOImpl personDAO){
        this.personDAO=personDAO;
       }
    public void addPerson(Person person) {
       personDAO.add(person);
       this.personDAO.commit();
    }
}
///////////////////////

public class MainApp {
    public static void main(String[] args) {
        Locale.setDefault(Locale.ENGLISH);
        AnnotationConfigApplicationContext ac=new AnnotationConfigApplicationContext(ConfigurationApp.class);
        PersonService person=ac.getBean(PersonService.class);
             Person person1=new Person();
                person1.setId(896);
                person1.setName("vali");
                person1.setFamily("hassanpoor");
                person1.setPassword(12579);
                person.addPerson(person1);
}