1c063fefb8b27817c1a367a10e99ab28f6d148e9
[mir.git] / source / mircoders / entity / EntityOther.java
1 /*
2  * Copyright (C) 2001, 2002  The Mir-coders group
3  *
4  * This file is part of Mir.
5  *
6  * Mir is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation; either version 2 of the License, or
9  * (at your option) any later version.
10  *
11  * Mir is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with Mir; if not, write to the Free Software
18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
19  *
20  * In addition, as a special exception, The Mir-coders gives permission to link
21  * the code of this program with the com.oreilly.servlet library, any library
22  * licensed under the Apache Software License, The Sun (tm) Java Advanced
23  * Imaging library (JAI), The Sun JIMI library (or with modified versions of
24  * the above that use the same license as the above), and distribute linked
25  * combinations including the two.  You must obey the GNU General Public
26  * License in all respects for all of the code used other than the above
27  * mentioned libraries.  If you modify this file, you may extend this exception
28  * to your version of the file, but you are not obligated to do so.  If you do
29  * not wish to do so, delete this exception statement from your version.
30  */
31
32 package mircoders.entity;
33
34 import java.lang.*;
35 import java.io.*;
36 import java.util.*;
37 import java.sql.*;
38
39 /*
40  * kind of hack for postgres non-standard LargeObjects that Poolman
41  * doesn't know about. see all the casting, LargeObj stuff in getIcon, getOther
42  * at some point when postgres has normal BLOB support, this should go.
43  */
44 import org.postgresql.Connection;
45 import org.postgresql.largeobject.LargeObject;
46 import org.postgresql.largeobject.LargeObjectManager;
47
48 import mir.entity.*;
49 import mir.misc.*;
50 import mir.storage.*;
51
52 /**
53  * This class handles storage of other data and meta data
54  *
55  * @author mh
56  * @version 11.11.2000
57  */
58
59
60 public class EntityOther extends EntityUploadedMedia
61 {
62         public EntityOther()
63         {
64                 super();
65         }
66
67         public EntityOther(StorageObject theStorage) {
68                 this();
69                 setStorage(theStorage);
70         }
71
72         //
73         // methods
74
75
76
77         public byte[] getOther() throws StorageObjectException
78         {
79                 theLog.printDebugInfo("--getother started");
80                 java.sql.Connection con=null;Statement stmt=null;
81                 byte[] img_data=null;
82
83                 try {
84                         con = theStorageObject.getPooledCon();
85                         con.setAutoCommit(false);
86                         LargeObjectManager lom;
87             java.sql.Connection jCon;
88             stmt = con.createStatement();
89                         ResultSet rs = theStorageObject.executeSql(stmt,
90                             "select other_data from other where id="+getId());
91             jCon = ((com.codestudio.sql.PoolManConnectionHandle)con)
92                     .getNativeConnection();
93             lom = ((org.postgresql.Connection)jCon).getLargeObjectAPI();
94                         if(rs!=null) {
95               if (rs.next()) {
96                 LargeObject lob = lom.open(rs.getInt(1));
97                 img_data = lob.read(lob.size());
98                 lob.close();
99                 //img_data = rs.getBytes(1);
100               }
101             rs.close();
102                         }
103                 } catch (Exception e) {
104           e.printStackTrace();
105           theLog.printError("EntityOther -- getOther failed"+e.toString()); 
106           throwStorageObjectException(e, "EntityOther -- getOther failed: ");
107         }
108         finally {
109           try {
110             con.setAutoCommit(true);
111           } catch (Exception e) {
112             e.printStackTrace();
113             theLog.printError(
114                     "EntityOther -- getOther reseting transaction mode failed"
115                     +e.toString()); 
116           }
117           theStorageObject.freeConnection(con,stmt);
118         }
119
120                 return img_data;
121         }
122
123         public void setOther(byte[] otherData, String otherType)
124             throws StorageObjectException {
125
126                 if (otherData!=null) {
127                         java.sql.Connection con=null;PreparedStatement pstmt=null;
128                         try {
129
130                                 theLog.printDebugInfo("settother :: making internal representation of other");
131                                 theLog.printDebugInfo("settother :: made internal representation of other");
132                                 theLog.printDebugInfo("settother :: getOther");
133
134                                 if ( otherData!=null) {
135                                         con = theStorageObject.getPooledCon();
136                                         con.setAutoCommit(false);
137                                         theLog.printDebugInfo("settother :: trying to insert other");
138
139                                         // setting values
140                                         pstmt.setBytes(1, otherData);
141                                         String sql="update content set is_produced='0' where to_media="+getId();
142                                         pstmt = con.prepareStatement(sql);
143                                         pstmt.executeUpdate();
144                                 }
145                         }
146                         catch (Exception e) {throwStorageObjectException(e, "settother :: setOther gescheitert: ");}
147                         finally {
148                                 try { if (con!=null) con.setAutoCommit(true); } catch (Exception e) {;}
149                                 theStorageObject.freeConnection(con,pstmt); }
150                 }
151         }
152
153         public void update() throws StorageObjectException {
154                 super.update();
155                 try {
156                         theStorageObject.executeUpdate("update content set is_produced='0' where to_media="+getId());
157                 } catch (SQLException e) {
158                         throwStorageObjectException(e, "EntityOther :: update :: failed!! ");
159                 }
160         }
161
162         public void setValues(HashMap theStringValues)
163         {
164                 if (theStringValues != null) {
165                         if (!theStringValues.containsKey("is_published"))
166                          theStringValues.put("is_published","0");
167                 }
168                 super.setValues(theStringValues);
169         }
170
171 }