Package org.bgerp.plugin.ai.aixflow.model

Class AixFlowResultDAO

java.lang.Object

org.bgerp.plugin.ai.aixflow.model.AixFlowResultDAO

public class AixFlowResultDAO
extends Object

DAO for aixflow_results table.

Constructor Summary

Constructors

Constructor	Description
AixFlowResultDAO()

Method Summary

Modifier and Type	Method	Description
static void	deleteByFilename(Connection con, String filename)
static List<AixFlowResult>	getAll(Connection con)
static AixFlowResult	getByAnalysisId(Connection con, String analysisId)
static List<AixFlowResult>	getByFilename(Connection con, String filename)
static List<AixFlowResult>	getPendingOrProcessing(Connection con)	Returns all records with status pending or processing (for poller).
static void	saveDiarizationResult(Connection con, String analysisId, String diarizationStatus, String diarizationResult, String diarizationRawResponse)	Update diarization fields for a result (stub — sets status only).
static void	saveResult(Connection con, AixFlowResult r)	Insert or update an analysis result (upsert on analysis_id).
static void	updateStatus(Connection con, String analysisId, String status, int progress)	Update status and progress for a result.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AixFlowResultDAO

public AixFlowResultDAO()

Method Details

saveResult

public static void saveResult(Connection con,
 AixFlowResult r)
                       throws SQLException

Insert or update an analysis result (upsert on analysis_id).

Throws:

SQLException

saveDiarizationResult

public static void saveDiarizationResult(Connection con,
 String analysisId,
 String diarizationStatus,
 String diarizationResult,
 String diarizationRawResponse)
                                  throws SQLException

Update diarization fields for a result (stub — sets status only).

Throws:

SQLException

updateStatus

public static void updateStatus(Connection con,
 String analysisId,
 String status,
 int progress)
                         throws SQLException

Update status and progress for a result.

Throws:

SQLException

getByAnalysisId

public static AixFlowResult getByAnalysisId(Connection con,
 String analysisId)
                                     throws SQLException

Throws:

SQLException

getByFilename

public static List<AixFlowResult> getByFilename(Connection con,
 String filename)
                                         throws SQLException

Throws:

SQLException

getAll

public static List<AixFlowResult> getAll(Connection con)
                                  throws SQLException

Throws:

SQLException

getPendingOrProcessing

public static List<AixFlowResult> getPendingOrProcessing(Connection con)
                                                  throws SQLException

Returns all records with status pending or processing (for poller).

Throws:

SQLException

deleteByFilename

public static void deleteByFilename(Connection con,
 String filename)
                             throws SQLException

Throws:

SQLException