Spring jdbc & transaction review.

Author: rainbowBPF2

.idea/artifacts/rainbow_war_exploded.xml

@@ -81,7 +81,17 @@
             <version>1.2.24</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.aspectj</groupId>
+            <artifactId>aspectjrt</artifactId>
+            <version>1.8.10</version>
+        </dependency>
 
+        <dependency>
+            <groupId>org.aspectj</groupId>
+            <artifactId>aspectjweaver</artifactId>
+            <version>1.8.10</version>
+        </dependency>
 
     </dependencies>
 </project>

.idea/libraries/Maven__org_aspectj_aspectjrt_1_8_10.xml

@@ -24,6 +24,7 @@
       <sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
       <sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" />
       <sourceFolder url="file://$MODULE_DIR$/src/test/resources" type="java-test-resource" />
+      <excludeFolder url="file://$MODULE_DIR$/target" />
     </content>
     <orderEntry type="inheritedJdk" />
     <orderEntry type="sourceFolder" forTests="false" />
@@ -56,6 +57,8 @@
     <orderEntry type="library" name="Maven: redis.clients:jedis:2.6.0" level="project" />
     <orderEntry type="library" name="Maven: org.apache.commons:commons-pool2:2.0" level="project" />
     <orderEntry type="library" name="Maven: com.alibaba:fastjson:1.2.24" level="project" />
+    <orderEntry type="library" name="Maven: org.aspectj:aspectjrt:1.8.10" level="project" />
+    <orderEntry type="library" name="Maven: org.aspectj:aspectjweaver:1.8.10" level="project" />
   </component>
   <component name="TemplatesService">
     <option name="TEMPLATE_FOLDERS">

.idea/libraries/Maven__org_aspectj_aspectjweaver_1_8_10.xml

@@ -0,0 +1,31 @@
+package dao;
+
+import domain.Student;
+
+import javax.sql.DataSource;
+import java.util.List;
+
+/**
+ * Created by pengfei on 2017/9/20.
+ */
+public interface StudentDao {
+
+    public void setDataSource(DataSource dataSource);
+
+    public void create(String name,String male,int age);
+
+    public Student findStudent(int id);
+
+    public List<Student> listStudents();
+
+    public void delete(int id);
+
+    public void update(int id,int age);
+
+    public Student getStudentByCall(int id);
+
+    public void transactionTest(int id,String name, String male);
+
+    public void declarativeTxTest(int age);
+
+}

.idea/workspace.xml

@@ -0,0 +1,126 @@
+package dao;
+
+import domain.Student;
+import domain.StudentMapper;
+import org.apache.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.DataAccessException;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
+import org.springframework.jdbc.core.namedparam.SqlParameterSource;
+import org.springframework.jdbc.core.simple.SimpleJdbcCall;
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.PlatformTransactionManager;
+import org.springframework.transaction.TransactionDefinition;
+import org.springframework.transaction.TransactionStatus;
+import org.springframework.transaction.support.DefaultTransactionDefinition;
+
+import javax.sql.DataSource;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Created by pengfei on 2017/9/20.
+ */
+
+@Repository
+public class StudentDaoImpl implements StudentDao {
+
+    private final static Logger logger = Logger.getLogger(StudentDaoImpl.class);
+
+    private DataSource dataSource;
+    private JdbcTemplate template;
+
+    @Autowired
+    private PlatformTransactionManager txManager;
+
+
+    @Autowired
+    public void setDataSource(DataSource dataSource) {
+        this.dataSource = dataSource;
+        this.template = new JdbcTemplate(dataSource);
+    }
+
+    public void create(String name, String male, int age) {
+        String sql = "insert into student (name, male,age) values(?, ?, ?)";
+        int rows = this.template.update(sql, name, male, age);
+        logger.info("Create a student in db, affect rows:" + rows);
+
+    }
+
+    public Student findStudent(int id) {
+        String sql = "select * from student where id = ?";
+        Student student = (Student) this.template.queryForObject(sql, new StudentMapper(), id);
+        logger.info("get student with id:" + id);
+        return student;
+    }
+
+    public List<Student> listStudents() {
+        String sql = "select * from student";
+        List<Student> students = this.template.query(sql, new StudentMapper());
+
+        logger.info("Got students");
+        return students;
+    }
+
+    public void delete(int id) {
+        String sql = "delete from student where id= ?";
+        this.template.update(sql, id);
+        logger.info("Delete student with id:" + id);
+    }
+
+    public void update(int id, int age) {
+        String sql = "update student set age =? where id= ?";
+        this.template.update(sql, age, id);
+
+    }
+
+    public Student getStudentByCall(int id) {
+        SimpleJdbcCall call = new SimpleJdbcCall(this.dataSource).withProcedureName("getStudentRecord");
+        SqlParameterSource in = new MapSqlParameterSource("in_id", id);
+
+        Map<String, Object> out = call.execute(in);
+
+        Student student = new Student();
+        student.setName((String) out.get("out_name"));
+        student.setAge((Integer) out.get("out_age"));
+
+        return student;
+    }
+
+    public void transactionTest(int id, String name, String male) {
+        TransactionDefinition def = new DefaultTransactionDefinition();
+        TransactionStatus status = txManager.getTransaction(def);
+
+        try {
+            String sql1 = "update student set name =? where id= ?";
+
+            this.template.update(sql1, name, id);
+
+            String sql2 = "insert into student (name, male) values (?, ?) ";
+            this.template.update(sql2, name, male);
+
+//            //Test transaction function.
+//            if (id % 2 == 1)
+//                throw new RecoverableDataAccessException("");
+
+            txManager.commit(status);
+            logger.info("Transaction test success in dao");
+        } catch (DataAccessException e) {
+            logger.error("error found in TX execution.");
+            txManager.rollback(status);
+            throw e;
+        }
+
+        return;
+    }
+
+    public void declarativeTxTest(int age) {
+        logger.info("dao tx begin");
+        String sql = "insert into student (name, age) values(?, ?)";
+        this.template.update(sql, "mary dianna", age);
+        if (age < 18)
+            throw new RuntimeException();
+        logger.info("dao tx end");
+    }
+}

pom.xml

@@ -0,0 +1,77 @@
+package domain;
+
+/**
+ * Created by pengfei on 2017/9/20.
+ */
+public class Student {
+    private int id;
+    private String name;
+    private String male;
+    private String comment;
+    private double salary;
+    private int age;
+
+    public Student() {
+
+    }
+
+    public Student(int age, String name, String male) {
+        this.age = age;
+        this.name = name;
+        this.male = male;
+    }
+
+    public int getAge() {
+        return age;
+    }
+
+    public void setAge(int age) {
+        this.age = age;
+    }
+
+    public double getSalary() {
+        return salary;
+    }
+
+    public void setSalary(double salary) {
+        this.salary = salary;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getMale() {
+        return male;
+    }
+
+    public void setMale(String male) {
+        this.male = male;
+    }
+
+    public String getComment() {
+        return comment;
+    }
+
+    public void setComment(String comment) {
+        this.comment = comment;
+    }
+
+    @Override
+    public String toString() {
+        String s=this.getId()+" "+getName()+" "+getAge()+" "+getMale()+" "+getComment();
+        return s;
+    }
+}

rainbow.iml

@@ -0,0 +1,24 @@
+package domain;
+
+import org.springframework.jdbc.core.RowMapper;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+/**
+ * Created by pengfei on 2017/9/20.
+ */
+public class StudentMapper implements RowMapper<Student> {
+    public Student mapRow(ResultSet rs, int i) throws SQLException {
+
+        Student student = new Student();
+        student.setId(rs.getInt("id"));
+        student.setName(rs.getString("name"));
+        student.setAge(rs.getInt("age"));
+        student.setMale(rs.getString("male"));
+        student.setSalary(rs.getDouble("salary"));
+        student.setComment(rs.getString("comment"));
+
+        return student;
+    }
+}

src/main/java/dao/StudentDao.java

@@ -0,0 +1,27 @@
+package service;
+
+import domain.Student;
+
+import java.util.List;
+
+/**
+ * Created by pengfei on 2017/9/20.
+ */
+public interface IStudentService {
+    public void insertStudent(Student student);
+
+    public void updateStudent(int id, int age);
+
+    public List<Student> getAllStudent();
+
+    public void deleteStudent(int id);
+
+    public Student queryStudent(int id);
+
+    public Student queryStudentByCall(int id);
+
+    public void testTxManager(int id, String name, String male);
+
+    public void testDeclarativeTx(int age);
+
+}