Blame view

src/main/java/fr/plil/sio/persistence/jdbc/RightRepositoryJdbc.java 3.79 KB
ef4eb263   rvangrev   Nouvelles modific...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
  /*
   * To change this license header, choose License Headers in Project Properties.
   * To change this template file, choose Tools | Templates
   * and open the template in the editor.
   */
  package fr.plil.sio.persistence.jdbc;
  
  import fr.plil.sio.persistence.api.Group;
  import java.sql.ResultSet;
  import java.sql.SQLException;
  import java.sql.Statement;
  import javax.sql.DataSource;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  import org.springframework.beans.factory.annotation.Autowired;
  import fr.plil.sio.persistence.api.Right;
  
  /**
   *
   * @author rvangrev
   */
  public class RightRepositoryJdbc implements RightRepository{
      
       private static final Logger logger = LoggerFactory.getLogger(GroupRepository.class);
  
      @Autowired
      private DataSource dataSource;
      
      @Override
      public Right findByName(String name) {
          Statement stmt = null;
          ResultSet rs = null;
          try {
              stmt = dataSource.getConnection().createStatement();
              rs = stmt.executeQuery("SELECT * FROM GROUP_T WHERE NAME_C = \'" + name + "\'");
              if (rs.next()) {
                  logger.debug("found group " + name);
  //                Group group = new Group();
  //                group.setId(rs.getLong("GROUP_ID"));
  //                group.setName(rs.getString("NAME_C"));
  //                return group;
              } else {
                  logger.debug("not found " + name);
                  return null;
              }
          } catch (SQLException e) {
              throw new UnsupportedOperationException("sql exception", e);
          } finally {
              try {
                  if (rs != null) {
                      rs.close();
                  }
                  if (stmt != null) {
                      stmt.close();
                  }
              } catch (SQLException e) {
                  throw new UnsupportedOperationException("sql exception during close", e);
  
              }
          }
          return null;
      }
  
      @Override
      public void save(Right right) {
          Statement stmt = null;
          ResultSet rs = null;
          try {
              stmt = dataSource.getConnection().createStatement();
e1ed8749   RĂ©mi Vangrevelynghe   save before merge
70
71
  
              stmt.executeUpdate("INSERT INTO GROUP_T (NAME_C, PARENT) VALUES (\'" + right.getName() + "\', \'" + right.getParent().getId() + "\')",
ef4eb263   rvangrev   Nouvelles modific...
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
                      Statement.RETURN_GENERATED_KEYS);
              rs = stmt.getGeneratedKeys();
              if (rs.next()) {
                  right.setId(rs.getLong(1));
              } else {
                  throw new UnsupportedOperationException("default in key access");
              }
          } catch (SQLException e) {
              throw new UnsupportedOperationException("sql exception", e);
          } finally {
              try {
                  if (rs != null) {
                      rs.close();
                  }
                  if (stmt != null) {
                      stmt.close();
                  }
              } catch (SQLException e) {
                  throw new UnsupportedOperationException("sql exception during close", e);
              }
          }
  
      }
  
      @Override
      public void delete(Long id) {
          Statement stmt = null;
          ResultSet rs = null;
          if(id==null){
              throw new IllegalArgumentException();
          }
          try {
              stmt = dataSource.getConnection().createStatement();
              stmt.execute("DELETE FROM RIGHT_T WHERE RIGHT_ID = " + id);
          } catch (SQLException e) {
              throw new UnsupportedOperationException("sql exception", e);
          } finally {
              try {
                  if (rs != null) {
                      rs.close();
                  }
                  if (stmt != null) {
                      stmt.close();
                  }
              } catch (SQLException e) {
                  throw new UnsupportedOperationException("sql exception during close", e);
              }
          }
      }
  }