DorisFlightSqlProducer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total540 of 1,33359%25 of 5453%49761333102949
executeQueryStatementLocked(String, ConnectContext, String, FlightDescriptor)7623975%81260%711156301
lambda$acceptPutPreparedStatementUpdate$2(FlightStream, FlightProducer.StreamListener)690%40%33181811
getStreamTables(FlightSql.CommandGetTables, FlightProducer.CallContext, FlightProducer.ServerStreamListener)450%20%22151511
getStreamSchemas(FlightSql.CommandGetDbSchemas, FlightProducer.CallContext, FlightProducer.ServerStreamListener)400%n/a11141411
getStreamCatalogs(FlightProducer.CallContext, FlightProducer.ServerStreamListener)370%n/a11131311
getStreamStatementResult(String, FlightProducer.ServerStreamListener)323954%n/a0151701
getFlightInfoStatement(FlightSql.CommandStatementQuery, FlightProducer.CallContext, FlightDescriptor)221540%n/a014601
handleStreamException(Throwable, String, FlightProducer.ServerStreamListener)190%n/a113311
lambda$createPreparedStatement$1(FlightProducer.CallContext, FlightSql.ActionCreatePreparedStatementRequest, FlightProducer.StreamListener)177982%3350%3432201
closeSession(CloseSessionRequest, FlightProducer.CallContext, FlightProducer.StreamListener)131553%n/a014901
getFlightInfoTables(FlightSql.CommandGetTables, FlightProducer.CallContext, FlightDescriptor)130%20%224411
close()90%n/a112211
serializeMetadata(Schema)71669%n/a012501
getStreamPreparedStatement(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightProducer.ServerStreamListener)70%n/a112211
getStreamSqlInfo(FlightSql.CommandGetSqlInfo, FlightProducer.CallContext, FlightProducer.ServerStreamListener)70%n/a112211
getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoCatalogs(FlightSql.CommandGetCatalogs, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoSchemas(FlightSql.CommandGetDbSchemas, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoTableTypes(FlightSql.CommandGetTableTypes, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoCrossReference(FlightSql.CommandGetCrossReference, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightDescriptor)510695%3770%3622701
preparedQuery(ConnectContext, FlightProducer.CallContext, FlightSql.CommandPreparedStatementQuery)55791%1583%1411601
lambda$closePreparedStatement$0(FlightSql.ActionClosePreparedStatementRequest, FlightProducer.StreamListener)52482%n/a0131001
listFlights(FlightProducer.CallContext, Criteria, FlightProducer.StreamListener)50%n/a111111
doExchange(FlightProducer.CallContext, FlightStream, FlightProducer.ServerStreamListener)50%n/a111111
acceptPutStatement(FlightSql.CommandStatementUpdate, FlightProducer.CallContext, FlightStream, FlightProducer.StreamListener)50%n/a111111
acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate, FlightProducer.CallContext, FlightStream, FlightProducer.StreamListener)50%n/a111111
acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightStream, FlightProducer.StreamListener)50%n/a112211
getStreamTypeInfo(FlightSql.CommandGetXdbcTypeInfo, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamTableTypes(FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamPrimaryKeys(FlightSql.CommandGetPrimaryKeys, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamExportedKeys(FlightSql.CommandGetExportedKeys, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamImportedKeys(FlightSql.CommandGetImportedKeys, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamCrossReference(FlightSql.CommandGetCrossReference, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
buildCreatePreparedStatementResult(ByteString, Schema, Schema)32488%2250%230601
DorisFlightSqlProducer(Location, FlightSessionsManager)46100%n/a0101201
getFlightInfoForSchema(Message, FlightDescriptor, Schema)29100%n/a010301
getSchemaPreparedStatement(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightDescriptor)23100%n/a010301
analyzeQuerySchema(ConnectContext, String)23100%n/a010601
executeQueryStatement(String, ConnectContext, String, FlightDescriptor)15100%n/a010201
getSchemaStatement(FlightSql.CommandStatementQuery, FlightProducer.CallContext, FlightDescriptor)13100%n/a010201
createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest, FlightProducer.CallContext, FlightProducer.StreamListener)10100%n/a010201
closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest, FlightProducer.CallContext, FlightProducer.StreamListener)9100%n/a010201
getStreamStatement(FlightSql.TicketStatementQuery, FlightProducer.CallContext, FlightProducer.ServerStreamListener)7100%n/a010201
static {...}4100%n/a010101