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 package org.exolab.castor.dsml;
48
49
50 import java.io.IOException;
51 import java.io.InputStream;
52 import java.io.Reader;
53 import java.util.Enumeration;
54 import java.util.TooManyListenersException;
55
56 import javax.naming.directory.SearchResult;
57
58 import org.castor.core.util.Messages;
59 import org.castor.xml.BackwardCompatibilityContext;
60 import org.castor.xml.InternalContext;
61 import org.xml.sax.InputSource;
62 import org.xml.sax.Parser;
63 import org.xml.sax.SAXException;
64
65
66
67
68
69
70
71
72 public abstract class Importer
73 {
74 private InternalContext _xmlContext = new BackwardCompatibilityContext();
75
76 private ImportDescriptor _importDesc;
77
78
79 private ImportEventListener _listener;
80
81
82 public void setImportDescriptor( ImportDescriptor importDesc )
83 {
84 _importDesc = importDesc;
85 }
86
87
88 public ImportDescriptor getImportDescriptor()
89 {
90 if ( _importDesc == null )
91 _importDesc = new ImportDescriptor();
92 return _importDesc;
93 }
94
95
96 public void setImportEventListener( ImportEventListener listener )
97 throws TooManyListenersException
98 {
99 if ( _listener != null )
100 throw new TooManyListenersException( Messages.message( "dsml.onlyOneListener" ) );
101 _listener = listener;
102 }
103
104
105 public ImportEventListener getImportEventListener()
106 {
107 return _listener;
108 }
109
110
111 public void importDocument( InputStream stream )
112 throws ImportExportException
113 {
114 importDocument( _xmlContext.getParser(), new InputSource( stream ) );
115 }
116
117
118 public void importDocument( Reader reader )
119 throws ImportExportException
120 {
121 importDocument( _xmlContext.getParser(), new InputSource( reader ) );
122 }
123
124
125 public void importDocument( Parser parser, InputSource input )
126 throws ImportExportException
127 {
128 Consumer consumer;
129
130 consumer = createConsumer();
131 parser.setDocumentHandler( consumer );
132 try {
133 parser.parse( input );
134 } catch ( SAXException except ) {
135 throw new ImportExportException( except );
136 } catch ( IOException except ) {
137 throw new ImportExportException( except );
138 }
139 if ( consumer.getResults() != null ) {
140 importEntries( consumer.getResults() );
141 }
142 }
143
144 public void readImportDescriptor( InputStream input )
145 throws IOException, SAXException
146 {
147 readImportDescriptor( _xmlContext.getParser(), new InputSource( input ) );
148 }
149
150
151 public void readImportDescriptor( Reader input )
152 throws IOException, SAXException
153 {
154 readImportDescriptor( _xmlContext.getParser(), new InputSource( input ) );
155 }
156
157
158 protected void readImportDescriptor( Parser parser, InputSource input )
159 throws IOException, SAXException
160 {
161 ImportDescriptor desc;
162
163 desc = new ImportDescriptor();
164 parser.setDocumentHandler( desc );
165 parser.parse( input );
166 setImportDescriptor( desc );
167 }
168
169
170 protected void notify( String name, int flag )
171 {
172 if ( _listener != null ) {
173 _listener.processedEntry( name, flag );
174 }
175 }
176
177
178 protected abstract Consumer createConsumer();
179
180
181 public abstract void importEntries(Enumeration<SearchResult> enumeration)
182 throws ImportExportException;
183 }
184