1 21 22 package org.continuent.sequoia.controller.virtualdatabase.protocol; 23 24 import java.io.Serializable ; 25 import java.sql.SQLException ; 26 27 import org.continuent.hedera.common.Member; 28 import org.continuent.sequoia.common.exceptions.ControllerException; 29 import org.continuent.sequoia.controller.requests.AbstractRequest; 30 import org.continuent.sequoia.controller.virtualdatabase.DistributedVirtualDatabase; 31 32 38 public class GetPreparedStatementMetadata 39 extends DistributedVirtualDatabaseMessage 40 { 41 private static final long serialVersionUID = 4898077898219570560L; 42 43 private AbstractRequest request; 44 45 50 public GetPreparedStatementMetadata(AbstractRequest request) 51 { 52 this.request = request; 53 } 54 55 59 public Object handleMessageSingleThreaded(DistributedVirtualDatabase dvdb, 60 Member sender) 61 { 62 try 63 { 64 return dvdb.getRequestManager().getPreparedStatementGetMetaData(request); 65 } 66 catch (SQLException e) 67 { 68 return new ControllerException(e); 69 } 70 } 71 72 76 public Serializable handleMessageMultiThreaded( 77 DistributedVirtualDatabase dvdb, Member sender, 78 Object handleMessageSingleThreadedResult) 79 { 80 return (Serializable ) handleMessageSingleThreadedResult; 81 } 82 83 } 84 | Popular Tags |