![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to Evaluator.m CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [NeXTSTEP 3.3 examples] / Examples / EnterpriseObjects / SQLExecutor|
Return to Evaluator.m CVS log | Up to [NeXTSTEP 3.3 examples] / Examples / EnterpriseObjects / SQLExecutor |
1.1 root 1: /* Evaluator.m:
2: * You may freely copy, distribute, and reuse the code in this example.
3: * NeXT disclaims any warranty of any kind, expressed or implied, as to its
4: * fitness for any particular use.
5: *
6: *
7: *
8: */
9:
10: #import <foundation/NSString.h>
11: #import <foundation/NSUtilities.h>
12:
13: #import "ScrollViewExtras.h"
14: #import "Evaluator.h"
15: #import "EOFDelegateAdaptorCategory.h"
16:
17:
18: #define FAILURE NXLocalizedString("Failure:", NULL, \
19: "Message given to user when an operation has failed.")
20:
21: #define CANNOT_CONNECT NXLocalizedString("Cannot connect to database", NULL, \
22: "Message given to user to explain what fails. ")
23:
24: #define OK NXLocalizedString("OK", NULL, "Okay to continue ")
25:
26: @implementation Evaluator
27:
28: - initWithModelFile:(NSString *)filePath
29: {
30: char path[MAXPATHLEN];
31: BOOL result=NO;
32:
33: [super init];
34:
35: // open the model file and connect to the database
36: model = [[[EOModel alloc]
37: initWithContentsOfFile: filePath] autorelease];
38:
39: if (!model)
40: return nil;
41:
42:
43: adaptor = [EOAdaptor adaptorWithModel:model];
44: if (!adaptor)
45: return nil;
46:
47: context = [adaptor createAdaptorContext];
48: if (!context)
49: return nil;
50:
51:
52: channel = [context createAdaptorChannel];
53:
54: if (!channel)
55: return nil;
56:
57: if (![channel isOpen])
58: result = [channel openChannel];
59: if (result)
60: [resultsView sprintf:"Connection successful\n"];
61: else
62: [resultsView sprintf:"Connection failed\n"];
63:
64: [[NXBundle mainBundle] getPath:path forResource:"SQLWindow" ofType:"nib"];
65: [NXApp loadNibFile:path owner:self withNames:NO];
66: [(Window *)[resultsView window] setDelegate:self];
67: [[resultsView window] setTitleAsFilename:[filePath cString]];
68: [[queryView docView] selectAll:self];
69: [[resultsView window] makeKeyAndOrderFront:self];
70:
71: /*----------------------------------------------------------------------
72: * set up the channel delegate to SybaseDelegate for Sybase model files
73: * use EOFDelegateCategory for Oracle model files
74: *--------------------------------------------------------------------*/
75:
76: if ([[adaptor name] isEqualToString:@"Sybase"]) {
77: sybaseDelegate = [[SybaseDelegate alloc] init];
78: [channel setDelegate:sybaseDelegate];
79: }
80: else {
81: sybaseDelegate = nil;
82: [channel setDelegate:[[EOFDelegateAdaptorCategory alloc] init]];
83: }
84:
85: return self;
86: }
87:
88: - free
89: {
90: [model release];
91: [adaptor release];
92: [context release];
93: [channel release];
94: if (sybaseDelegate)
95: [sybaseDelegate release];
96:
97: return [super free];
98: }
99:
100: - evaluate:sender
101: {
102: BOOL result = NO;
103: int charCount;
104: char *buffer = NULL;
105: NSDictionary *row;
106:
107: /*----------------------------------------------------------------------
108: * get the SQL statement
109: *--------------------------------------------------------------------*/
110:
111: if ((charCount = [[queryView docView] textLength]) > 0) {
112: buffer = malloc((charCount+1) * sizeof(char));
113: [[queryView docView] getSubstring:buffer start:0 length:charCount];
114: buffer[charCount] = 0;
115: while (charCount > 0 && buffer[--charCount] == '\n')
116: buffer[charCount] = 0;
117: [resultsView sprintf:"%s\n", buffer];
118:
119: }
120: else {
121: [resultsView sprintf:"Can't execute an empty string!\n"];
122: return self;
123: }
124:
125: /*----------------------------------------------------------------------
126: * evaluate the SQL statement
127: *--------------------------------------------------------------------*/
128:
129: [context beginTransaction];
130: result = [channel evaluateExpression:
131: [[NSString alloc] initWithCString:(const char *)buffer]];
132:
133: if (result){
134: [resultsView sprintf:"SQL successfully evaluated\n"];
135:
136: while ([channel isFetchInProgress] == YES) {
137: // get the array of attributes from the result set
138: attributes = [channel describeResults];
139:
140: // since the EO Framework attributes are stored as Attribute1,
141: // Attribute2, etc., build a dictionary to do conversion.
142:
143: [self buildColumnNamesDictionary:attributes];
144:
145: // The NSDictionary contains all the data for one row
146: while ((row = [channel fetchAttributes: attributes withZone:
147: [adaptor zone]]) != nil)
148: // read data back
149: [self readDataFromDict:row ];
150:
151: }
152: [context commitTransaction];
153:
154: }
155: else {
156: // do clean-up if SQL statement cannot be evaluated.
157: [resultsView sprintf:"SQL evaluation failed\n"];
158: if ([channel isFetchInProgress] == YES)
159: [channel cancelFetch];
160: [context rollbackTransaction];
161: }
162: free(buffer);
163: return self;
164: }
165:
166:
167:
168: /* Build a dictionary where the Keys are Attribute1, Attribute2, etc.,
169: * while the values are the actual column names as specified in the
170: * database.
171: */
172: - buildColumnNamesDictionary:(NSArray *) attributesArray
173: {
174: NSEnumerator *enumerator;
175: EOAttribute *attribute;
176: NSMutableArray *keys = [NSMutableArray array];
177: NSMutableArray *values = [NSMutableArray array];
178:
179: enumerator = [attributesArray objectEnumerator];
180:
181: while ((attribute = [enumerator nextObject]) != nil) {
182: [keys addObject:[attribute name]];
183: [values addObject:[attribute columnName]];
184: }
185: columnNamesDict = [NSDictionary dictionaryWithObjects:values
186: forKeys: keys];
187: return self;
188: }
189:
190: /* Cycle through the key and value pairs of the dictionary
191: * and print them to result view
192: *
193: */
194: - readDataFromDict:(NSDictionary *) dictionary
195: {
196: NSEnumerator *keyEnumerator;
197: NSString * key;
198: NSString * newKey;
199: id value;
200: char buffer[1024];
201: SybaseRowType rowType=0;
202:
203: keyEnumerator = [dictionary keyEnumerator];
204: if (sybaseDelegate)
205: rowType = [sybaseDelegate currentRowType];
206:
207: //print the full dictionary for Sybase regular rows or if the Oracle adaptor is used
208: if ( ((sybaseDelegate) && (rowType == SybaseRegularRow ))
209: || (sybaseDelegate == nil) )
210: {
211: while ((key = [keyEnumerator nextObject]) != nil) {
212: newKey = [columnNamesDict objectForKey:[key description]];
213:
214: value = [dictionary objectForKey:key];
215: sprintf(buffer, "%s: \t %s\n", [[newKey description] cString],
216: [[(NSObject *)value description] cString]);
217: [resultsView sprintf:buffer];
218: }
219: }
220: else {
221: // This must be one special sybase row
222: switch (rowType) {
223: case SybaseComputeRow:
224: case SybaseReturnStatusRow:
225: // print one row of data only
226: key = [keyEnumerator nextObject];
227: value = [dictionary objectForKey:key];
228: sprintf(buffer, "Row type: %s \t %s\n", (rowType == SybaseComputeRow) ?
229: "SybaseComputeRow": "SybaseReturnStatusRow",
230: [[(NSObject *)value description] cString]);
231: [resultsView sprintf:buffer];
232: sprintf(buffer, "************************************\n");
233: [resultsView sprintf:buffer];
234: break;
235: case SybaseReturnParameterRow:
236: // Exercise for the reader: How to format this row
237: [resultsView sprintf:"SybaseReturnParameterRow: No data printed\n"];
238: break;
239: case SybaseRegularRow:
240: default:
241: break;
242: }
243: }
244:
245:
246: return self;
247: }
248:
249: - clear:sender
250: {
251: [resultsView clear:sender];
252: [[queryView docView] selectText:self];
253: return self;
254: }
255:
256: - close:sender
257: {
258: // close the adaptor channel and disconnect from the database
259: [channel closeChannel];
260: // close the main window
261: [[NXApp mainWindow] performClose:sender];
262: return self;
263: }
264:
265:
266:
267: /*--------------------------------------------------------------------------
268: * Announcing Trace Info
269: *------------------------------------------------------------------------*/
270: - (void) logString:(NSString *) aString
271: {
272: [resultsView sprintf: "%s", [aString cString]];
273: }
274:
275: - (void) announce:sender selector:(SEL)selector
276: {
277: return [self announce:sender selector:selector with:nil];
278: }
279:
280:
281: - (void) announce:sender selector:(SEL)selector with:array
282: {
283: NSMutableString *string;
284:
285: string = [NSMutableString stringWithFormat:@"BEGIN> {Sender = %s%s",
286: [[(NSObject *)[sender class] description] cString], "}" ];
287:
288:
289: [string appendFormat:@" \n\t{Delegate Method = %s} ", sel_getName(selector)];
290:
291: if (array)
292: {
293: id object;
294: id verboseString = [NSMutableString stringWithCapacity:0];
295: id enumerator = [array objectEnumerator];
296:
297: while ((object = [enumerator nextObject]) != nil)
298: [verboseString
299: appendFormat:@"\n\t{Argument = %s} \n\t{Argument Description = %s} ",
300: [[(NSObject *)[object class] description] cString],
301: [[(NSObject *) object description] cString]];
302:
303: [string appendString:verboseString];
304: }
305:
306:
307: [string appendFormat:@"\n"];
308: [resultsView sprintf: "%s", [string cString]];
309: }
310:
311:
312: /* Window Delegate method -- constrain window resizing */
313:
314: - windowWillResize:sender toSize:(NXSize *)frameSize
315: {
316: if ( frameSize->height < 230 ) frameSize->height= 230;
317: return self;
318: }
319:
320:
321: @end
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.