| | |
| | | import de.uhilger.radiozentrale.daten.Sender; |
| | | import de.uhilger.radiozentrale.web.Initialiser; |
| | | import java.sql.Connection; |
| | | import java.util.ArrayList; |
| | | import java.util.Collections; |
| | | import java.util.Iterator; |
| | | import java.util.List; |
| | | |
| | | /** |
| | |
| | | Sender neuerSender = null; |
| | | PersistenceManager db = getDb(); |
| | | Connection c = db.getConnection(); |
| | | db.startTransaction(c); |
| | | List<List<String>> list = db.select(getSql(SQL_GET_NEXT_KEY), GenericRecord.WITHOUT_BLOBS, KEY_SENDER_ID); |
| | | if(list != null && list.size() > 0) { |
| | | int nextKey = Integer.parseInt(list.get(1).get(0)); |
| | | if(list != null && list.size() > 1) { |
| | | int nextKey = Integer.parseInt(list.get(1).get(0)); // erster Datensatz ist Ueberschrift |
| | | db.startTransaction(c); |
| | | db.execute(getSql(SQL_INCREMENT_KEY), nextKey+1, KEY_SENDER_ID, nextKey); |
| | | sender.setId(nextKey); |
| | | Object o = getDb().insert(sender, getMapper(Initialiser.MP_SENDER)); |
| | | if(o instanceof Sender) { |
| | | neuerSender = (Sender) o; |
| | | db.commit(c); |
| | | } else { |
| | | db.rollback(c); |
| | | } |
| | | } |
| | | db.commit(c); |
| | | return neuerSender; |
| | | } |
| | | |
| | | public List senderliste() { |
| | | String sql = getSql(SQL_GET_SENDER); |
| | | return getDb().select(sql, getMapper(Initialiser.MP_SENDER)); |
| | | return getDb().select(getSql(SQL_GET_SENDER), getMapper(Initialiser.MP_SENDER)); |
| | | } |
| | | } |