ArKTS: DAL，Model，BLL，Interface，Factory using SQLite

HarmonyOS 用@ohos.data.rdb 用DBHelper.ets 共用調用SQLite 庫，進行DAL,Model,BLL,Interface,Factory 框架模式，表為

CREATE TABLE IF NOT EXISTS signInRecord (
id INTEGER PRIMARY KEY AUTOINCREMENT,
employeeId TEXT NOT NULL,
employeeName TEXT NOT NULL,
signInTime TEXT NOT NULL
)

項目結構：
UtilitieDB
--DBHelper.ets
DAL
--signIn.ets
Model
--signIn.ets
BLL
----signIn.ets
Interface
----IsignIn.ets
Factory
--AbstractFactory.ets

/*
# encoding: utf-8
# 版權所有  2025 ?涂聚文有限公司? ?
# 許可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎
# 描述：
# Author    : geovindu,Geovin Du 涂聚文.
# IDE       : DevEco Studio 5.1.1 HarmonyOS
# os        : windows 10
# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j
# Datetime  : 2025/7/22 19:11
# User      :  geovindu
# Product   : DevEco Studio
# Project   : MyApplication
# File      : signIn.ets
*/export interface SignInRecordDbObject {id?: number;employeeId: string;employeeName: string;signInTime: string;
}export class SignInRecord {id: number | null;employeeId: string;employeeName: string;signInTime: string;constructor(employeeId: string,employeeName: string,signInTime: string,id: number | null = null) {this.id = id;this.employeeId = employeeId;this.employeeName = employeeName;this.signInTime = signInTime;}// 轉換為數據庫存儲的對象格式（類型安全版本）toDbObject(): SignInRecordDbObject {const dbObject: SignInRecordDbObject = {employeeId: this.employeeId,employeeName: this.employeeName,signInTime: this.signInTime};if (this.id !== null) {dbObject.id = this.id;}return dbObject;}// 從數據庫對象創建模型實例（類型安全版本）static fromDbObject(dbObject: SignInRecordDbObject): SignInRecord {return new SignInRecord(dbObject.employeeId,dbObject.employeeName,dbObject.signInTime,dbObject.id !== undefined ? dbObject.id : null);}
}/*
# encoding: utf-8
# 版權所有  2025 ?涂聚文有限公司? ?
# 許可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎
# 描述：
# Author    : geovindu,Geovin Du 涂聚文.
# IDE       : DevEco Studio 5.1.1 HarmonyOS
# os        : windows 10
# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j
# Datetime  : 2025/7/22 19:04
# User      :  geovindu
# Product   : DevEco Studio
# Project   : MyApplication
# File      : DBHelper.ets
*/import relationalStore from '@ohos.data.relationalStore';
import { BusinessError } from '@ohos.base';
import { Context } from '@ohos.abilityAccessCtrl';export class DBHelper {private static readonly DB_NAME: string = 'signInDB.db';private static readonly DB_VERSION: number = 1;private rdbStore: relationalStore.RdbStore | null = null;private static instance: DBHelper | null = null;private context: Context | null = null; // 新增上下文存儲private constructor() {}/**** @returns*/public static getInstance(): DBHelper {if (!DBHelper.instance) {DBHelper.instance = new DBHelper();}if (!DBHelper.instance) {throw new Error('無法創建DBHelper實例，請檢查實現');}return DBHelper.instance;}/*** 初始化數據庫時保存上下文* @param context* @returns*/public async initDB(context: Context): Promise<relationalStore.RdbStore> {if (this.rdbStore) {return this.rdbStore;}/*** 保存上下文供后續使用*/this.context = context;const storeConfig: relationalStore.StoreConfig = {name: DBHelper.DB_NAME,securityLevel: relationalStore.SecurityLevel.S1};try {this.rdbStore = await relationalStore.getRdbStore(context, storeConfig);await this.createTables();return this.rdbStore;} catch (error) {const err = error as BusinessError;console.error(`初始化數據庫失敗: ${err.code} - ${err.message}`);throw new Error(`數據庫初始化失敗: ${err.message}`);}}/**** @returns*/private async createTables(): Promise<void> {if (!this.rdbStore) {throw new Error('數據庫未初始化，請先調用initDB方法');}const createTableSql: string = `CREATE TABLE IF NOT EXISTS signInRecord (id INTEGER PRIMARY KEY AUTOINCREMENT,employeeId TEXT NOT NULL,employeeName TEXT NOT NULL,signInTime TEXT NOT NULL)`;try {await this.rdbStore.executeSql(createTableSql);console.log('簽到記錄表創建成功或已存在');} catch (error) {const err = error as BusinessError;console.error(`創建簽到記錄表失敗: ${err.code} - ${err.message}`);throw new Error(`創建數據表失敗: ${err.message}`);}}/**** @returns*/public getRdbStore(): relationalStore.RdbStore | null {if (!this.rdbStore) {console.warn('數據庫尚未初始化，請先調用initDB方法');}return this.rdbStore;}/*** 修正關閉數據庫的方法* @returns*/public async closeDB(): Promise<void> {if (this.rdbStore && this.context) {try {// 正確調用deleteRdbStore，需要傳入上下文和數據庫名稱await relationalStore.deleteRdbStore(this.context, DBHelper.DB_NAME);this.rdbStore = null;this.context = null; // 清除上下文console.log('數據庫已關閉并刪除');} catch (error) {const err = error as BusinessError;console.error(`關閉數據庫失敗: ${err.code} - ${err.message}`);throw new Error(`關閉數據庫失敗: ${err.message}`);}} else {if (!this.context) {console.warn('上下文不存在，無法關閉數據庫');} else {console.warn('數據庫連接不存在，無需關閉');}}}
}/*
# encoding: utf-8
# 版權所有  2025 ?涂聚文有限公司? ?
# 許可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎
# 描述：
# Author    : geovindu,Geovin Du 涂聚文.
# IDE       : DevEco Studio 5.1.1 HarmonyOS
# os        : windows 10
# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j
# Datetime  : 2025/7/22 19:14
# User      :  geovindu
# Product   : DevEco Studio
# Project   : MyApplication
# File      : IsignIn.ets
*/import { SignInRecord } from '../model/signIn';export interface ISignIn {/*** 添加簽到記錄* @param record* @returns*/addSignInRecord(record: SignInRecord): Promise<number>;/*** 根據ID獲取簽到記錄* @param id* @returns*/getSignInRecordById(id: number): Promise<SignInRecord | null>;/*** 獲取所有簽到記錄* @returns*/getAllSignInRecords(): Promise<SignInRecord[]>;/*** 根據員工ID獲取簽到記錄* @param employeeId* @returns*/getSignInRecordsByEmployeeId(employeeId: string): Promise<SignInRecord[]>;/*** 更新簽到記錄* @param record* @returns*/updateSignInRecord(record: SignInRecord): Promise<number>;/*** 刪除簽到記錄* @param id* @returns*/deleteSignInRecord(id: number): Promise<number>;
}/*
# encoding: utf-8
# 版權所有  2025 ?涂聚文有限公司? ?
# 許可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎
# 描述：
# Author    : geovindu,Geovin Du 涂聚文.
# IDE       : DevEco Studio 5.1.1 HarmonyOS
# os        : windows 10
# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j
# Datetime  : 2025/7/22 19:16
# User      :  geovindu
# Product   : DevEco Studio
# Project   : MyApplication
# File      : AbstractFactory.ets
*/
import { ISignIn } from '../Interface/IsignIn';
import { SignInDAL } from '../DAL/signIn';
import { SignInBLL } from '../BLL/signIn';/*** 抽象工廠類*/
export abstract class AbstractFactory {// 創建數據訪問層實例public abstract createSignInDAL(): ISignIn;// 創建業務邏輯層實例public abstract createSignInBLL(): ISignIn;
}/*** 簽到記錄工廠類*/
export class SignInFactory extends AbstractFactory {// 創建簽到記錄數據訪問層實例public createSignInDAL(): ISignIn {return new SignInDAL();}/*** 創建簽到記錄業務邏輯層實例* @returns*/public createSignInBLL(): ISignIn {// 可以在這里注入不同的DAL實現，方便測試或切換數據源const dal = this.createSignInDAL();return new SignInBLL(dal);}
}/*
# encoding: utf-8
# 版權所有  2025 ?涂聚文有限公司? ?
# 許可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎
# 描述：
# Author    : geovindu,Geovin Du 涂聚文.
# IDE       : DevEco Studio 5.1.1 HarmonyOS
# os        : windows 10
# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j
# Datetime  : 2025/7/22 19:17
# User      :  geovindu
# Product   : DevEco Studio
# Project   : MyApplication
# File      : signIn.ets
*/
import relationalStore from '@ohos.data.relationalStore';
import { DBHelper } from '../UtilitieDB/DBHelper';
import { SignInRecord, SignInRecordDbObject } from '../model/signIn';
import { ISignIn } from '../Interface/IsignIn';
import { BusinessError } from '@ohos.base';// 定義與數據庫字段對應的類型映射
type SignInColumn = 'id' | 'employeeId' | 'employeeName' | 'signInTime';export class SignInDAL implements ISignIn {private getRdbStore() {const rdbStore = DBHelper.getInstance().getRdbStore();if (!rdbStore) {throw new Error('數據庫未初始化，請先調用initDB方法');}return rdbStore;}/*** 添加簽到記錄* @param record* @returns*/async addSignInRecord(record: SignInRecord): Promise<number> {try {const dbObject = record.toDbObject();// 構建符合要求的ValuesBucketconst valuesBucket: relationalStore.ValuesBucket = {'employeeId': dbObject.employeeId,'employeeName': dbObject.employeeName,'signInTime': dbObject.signInTime};const rowId = await this.getRdbStore().insert('signInRecord', valuesBucket);return rowId;} catch (error) {const err = error as BusinessError;console.error(`添加簽到記錄失敗: ${err.code} - ${err.message}`);throw new Error(`添加簽到記錄失敗: ${err.message}`);}}/*** 根據ID獲取簽到記錄* @param id* @returns*/async getSignInRecordById(id: number): Promise<SignInRecord | null> {try {const predicates = new relationalStore.RdbPredicates('signInRecord');predicates.equalTo('id', id);const resultSet = await this.getRdbStore().query(predicates, ['*']);let record: SignInRecord | null = null;if (await resultSet.goToFirstRow()) {const dbObject: SignInRecordDbObject = {id: resultSet.getLong(resultSet.getColumnIndex('id')),employeeId: resultSet.getString(resultSet.getColumnIndex('employeeId')),employeeName: resultSet.getString(resultSet.getColumnIndex('employeeName')),signInTime: resultSet.getString(resultSet.getColumnIndex('signInTime'))};record = SignInRecord.fromDbObject(dbObject);}await resultSet.close();return record;} catch (error) {const err = error as BusinessError;console.error(`查詢簽到記錄失敗: ${err.code} - ${err.message}`);throw new Error(`查詢簽到記錄失敗: ${err.message}`);}}/*** 根據員工ID獲取簽到記錄* @param employeeId* @returns*/async getSignInRecordsByEmployeeId(employeeId: string): Promise<SignInRecord[]> {try {const predicates = new relationalStore.RdbPredicates('signInRecord');predicates.equalTo('employeeId', employeeId).orderByDesc('signInTime');const resultSet = await this.getRdbStore().query(predicates, ['*']);const records: SignInRecord[] = [];while (await resultSet.goToNextRow()) {const dbObject: SignInRecordDbObject = {id: resultSet.getLong(resultSet.getColumnIndex('id')),employeeId: resultSet.getString(resultSet.getColumnIndex('employeeId')),employeeName: resultSet.getString(resultSet.getColumnIndex('employeeName')),signInTime: resultSet.getString(resultSet.getColumnIndex('signInTime'))};records.push(SignInRecord.fromDbObject(dbObject));}await resultSet.close();return records;} catch (error) {const err = error as BusinessError;console.error(`根據員工ID查詢簽到記錄失敗: ${err.code} - ${err.message}`);throw new Error(`根據員工ID查詢簽到記錄失敗: ${err.message}`);}}/*** 獲取所有簽到記錄* @returns*/async getAllSignInRecords(): Promise<SignInRecord[]> {try {const predicates = new relationalStore.RdbPredicates('signInRecord');predicates.orderByDesc('signInTime');const resultSet = await this.getRdbStore().query(predicates, ['*']);const records: SignInRecord[] = [];while (await resultSet.goToNextRow()) {const dbObject: SignInRecordDbObject = {id: resultSet.getLong(resultSet.getColumnIndex('id')),employeeId: resultSet.getString(resultSet.getColumnIndex('employeeId')),employeeName: resultSet.getString(resultSet.getColumnIndex('employeeName')),signInTime: resultSet.getString(resultSet.getColumnIndex('signInTime'))};records.push(SignInRecord.fromDbObject(dbObject));}await resultSet.close();return records;} catch (error) {const err = error as BusinessError;console.error(`獲取所有簽到記錄失敗: ${err.code} - ${err.message}`);throw new Error(`獲取所有簽到記錄失敗: ${err.message}`);}}/*** 更新簽到記錄* @param record* @returns*/async updateSignInRecord(record: SignInRecord): Promise<number> {if (record.id === null) {throw new Error('更新失敗，簽到記錄ID不能為空');}try {const dbObject = record.toDbObject();const predicates = new relationalStore.RdbPredicates('signInRecord');predicates.equalTo('id', record.id); // 這里已經指定了要更新的記錄ID// 構建ValuesBucket，不包含id字段，因為不需要更新主鍵const valuesBucket: relationalStore.ValuesBucket = {'employeeId': dbObject.employeeId,'employeeName': dbObject.employeeName,'signInTime': dbObject.signInTime};// 執行更新操作const rowsUpdated = await this.getRdbStore().update(valuesBucket, predicates);return rowsUpdated;} catch (error) {const err = error as BusinessError;console.error(`更新簽到記錄失敗: ${err.code} - ${err.message}`);throw new Error(`更新簽到記錄失敗: ${err.message}`);}}/*** 刪除簽到記錄* @param id* @returns*/async deleteSignInRecord(id: number): Promise<number> {try {const predicates = new relationalStore.RdbPredicates('signInRecord');predicates.equalTo('id', id);const rowsDeleted = await this.getRdbStore().delete(predicates);return rowsDeleted;} catch (error) {const err = error as BusinessError;console.error(`刪除簽到記錄失敗: ${err.code} - ${err.message}`);throw new Error(`刪除簽到記錄失敗: ${err.message}`);}}/*** 將結果集轉換為簽到記錄數組* @param resultSet* @returns*/private convertResultSetToSignInRecords(resultSet: relationalStore.ResultSet): SignInRecord[] {const records: SignInRecord[] = [];resultSet.goToFirstRow();do {const record = this.convertResultSetToSignInRecord(resultSet);records.push(record);} while (resultSet.goToNextRow());return records;}/*** 結果集轉換為單個簽到記錄* @param resultSet* @returns*/private convertResultSetToSignInRecord(resultSet: relationalStore.ResultSet): SignInRecord {return new SignInRecord(resultSet.getString(resultSet.getColumnIndex('employeeId')),resultSet.getString(resultSet.getColumnIndex('employeeName')),resultSet.getString(resultSet.getColumnIndex('signInTime')),resultSet.getLong(resultSet.getColumnIndex('id')));}}/*
# encoding: utf-8
# 版權所有  2025 ?涂聚文有限公司? ?
# 許可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎
# 描述：
# Author    : geovindu,Geovin Du 涂聚文.
# IDE       : DevEco Studio 5.1.1 HarmonyOS
# os        : windows 10
# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j
# Datetime  : 2025/7/22 18:18
# User      :  geovindu
# Product   : DevEco Studio
# Project   : MyApplication
# File      : signIn.ets
*/
import { ISignIn } from '../Interface/IsignIn';
import { SignInRecord } from '../model/signIn';
import { SignInDAL } from '../DAL/signIn';export class SignInBLL implements ISignIn {private signInDAL: ISignIn;constructor(signInDAL: ISignIn = new SignInDAL()) {this.signInDAL = signInDAL;}/*** 添加簽到記錄，包含業務邏輯驗證* @param record* @returns*/async addSignInRecord(record: SignInRecord): Promise<number> {// 業務邏輯驗證：檢查必要字段if (!record.employeeId || record.employeeId.trim() === '') {throw new Error('員工ID不能為空');}if (!record.employeeName || record.employeeName.trim() === '') {throw new Error('員工姓名不能為空');}// 檢查簽到時間格式是否合法if (!this.isValidDateTime(record.signInTime)) {throw new Error('簽到時間格式不正確');}// 調用數據訪問層添加記錄return this.signInDAL.addSignInRecord(record);}/*** 根據ID獲取簽到記錄* @param id* @returns*/async getSignInRecordById(id: number): Promise<SignInRecord | null> {if (id <= 0) {throw new Error('無效的記錄ID');}return this.signInDAL.getSignInRecordById(id);}/*** 獲取所有簽到記錄* @returns*/async getAllSignInRecords(): Promise<SignInRecord[]> {return this.signInDAL.getAllSignInRecords();}/*** 根據員工ID獲取簽到記錄* @param employeeId* @returns*/async getSignInRecordsByEmployeeId(employeeId: string): Promise<SignInRecord[]> {if (!employeeId || employeeId.trim() === '') {throw new Error('員工ID不能為空');}return this.signInDAL.getSignInRecordsByEmployeeId(employeeId);}/*** 更新簽到記錄* @param record* @returns*/async updateSignInRecord(record: SignInRecord): Promise<number> {if (!record.id) {throw new Error('簽到記錄ID不能為空');}/*** 驗證更新的數據*/if (!record.employeeId || record.employeeId.trim() === '') {throw new Error('員工ID不能為空');}if (!this.isValidDateTime(record.signInTime)) {throw new Error('簽到時間格式不正確');}return this.signInDAL.updateSignInRecord(record);}/*** 刪除簽到記錄* @param id* @returns*/async deleteSignInRecord(id: number): Promise<number> {if (id <= 0) {throw new Error('無效的記錄ID');}return this.signInDAL.deleteSignInRecord(id);}// 驗證日期時間格式 (YYYY-MM-DD HH:MM:SS)private isValidDateTime(dateTime: string): boolean {const regex = /^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}$/;return regex.test(dateTime);}
}/*
# encoding: utf-8
# 版權所有  2025 ?涂聚文有限公司? ?
# 許可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎
# 描述：
# Author    : geovindu,Geovin Du 涂聚文.
# IDE       : DevEco Studio 5.1.1 HarmonyOS
# os        : windows 10
# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j
# Datetime  : 2025/7/22 18:56
# User      :  geovindu
# Product   : DevEco Studio
# Project   : MyApplication
# File      : SignInExample.ets
*/
import { Context } from '@ohos.abilityAccessCtrl';
import { SignInFactory } from '../Factory/AbstractFactory';
import { DBHelper } from '../UtilitieDB/DBHelper';
import { SignInRecord } from '../model/signIn';
import { ISignIn } from '../Interface/IsignIn';export class SignInExample {private signInBLL: ISignIn;constructor(context: Context) {// 初始化數據庫this.initDatabase(context);// 通過工廠獲取BLL實例const factory = new SignInFactory();this.signInBLL = factory.createSignInBLL();}/*** 初始化數據庫* @param context*/private async initDatabase(context: Context) {try {await DBHelper.getInstance().initDB(context);console.log('數據庫初始化成功');} catch (error) {console.error('數據庫初始化失敗:', error);}}/*** 添加簽到記錄示例* @returns*/async addSignInRecordExample() {try {// 創建簽到記錄對象const now = new Date();const signInTime = `${now.getFullYear()}-${(now.getMonth() + 1).toString().padStart(2, '0')}-${now.getDate().toString().padStart(2, '0')} ${now.getHours().toString().padStart(2, '0')}:${now.getMinutes().toString().padStart(2, '0')}:${now.getSeconds().toString().padStart(2, '0')}`;const record = new SignInRecord('EMP001',       // employeeId'張三',          // employeeNamesignInTime       // signInTime);// 調用BLL層添加記錄const rowId = await this.signInBLL.addSignInRecord(record);console.log(`添加簽到記錄成功，ID: ${rowId}`);return rowId;} catch (error) {console.error('添加簽到記錄失敗:', error);return null;}}/*** 查詢簽到記錄示例*/async querySignInRecordsExample() {try {// 1. 查詢所有簽到記錄const allRecords = await this.signInBLL.getAllSignInRecords();console.log(`所有簽到記錄(${allRecords.length}條):`, allRecords);// 2. 根據ID查詢記錄（假設我們知道一個存在的ID）if (allRecords.length > 0) {const firstRecordId = allRecords[0].id;if (firstRecordId !== null) {const singleRecord = await this.signInBLL.getSignInRecordById(firstRecordId);console.log(`ID為${firstRecordId}的簽到記錄:`, singleRecord);}}// 3. 根據員工ID查詢記錄const empRecords = await this.signInBLL.getSignInRecordsByEmployeeId('EMP001');console.log(`員工EMP001的簽到記錄(${empRecords.length}條):`, empRecords);return allRecords;} catch (error) {console.error('查詢簽到記錄失敗:', error);return null;}}/**** @param id* @returns*/async querySignInRecordsExampleId(id:string) {try {// 1. 查詢所有簽到記錄const allRecords = await this.signInBLL.getSignInRecordsByEmployeeId(id);console.log(`所有簽到記錄(${allRecords.length}條):`, allRecords);// 2. 根據ID查詢記錄（假設我們知道一個存在的ID）if (allRecords.length > 0) {const firstRecordId = allRecords[0].id;if (firstRecordId !== null) {const singleRecord = await this.signInBLL.getSignInRecordById(firstRecordId);console.log(`ID為${firstRecordId}的簽到記錄:`, singleRecord);}}// 3. 根據員工ID查詢記錄const empRecords = await this.signInBLL.getSignInRecordsByEmployeeId('EMP001');console.log(`員工EMP001的簽到記錄(${empRecords.length}條):`, empRecords);return allRecords;} catch (error) {console.error('查詢簽到記錄失敗:', error);return null;}}/*** 更新簽到記錄示例* @param recordId*/async updateSignInRecordExample(recordId: number) {try {// 先查詢要更新的記錄const record = await this.signInBLL.getSignInRecordById(recordId);if (!record) {console.log(`未找到ID為${recordId}的簽到記錄`);return -1;}// 修改記錄內容record.employeeName = '張三(更新)'; // 修改員工姓名// 調用BLL層更新記錄const rowsUpdated = await this.signInBLL.updateSignInRecord(record);console.log(`更新成功，影響行數: ${rowsUpdated}`);// 驗證更新結果const updatedRecord = await this.signInBLL.getSignInRecordById(recordId);console.log('更新后的記錄:', updatedRecord);return 1;} catch (error) {console.error('更新簽到記錄失敗:', error);return -1;}}/*** 刪除簽到記錄示例* @param recordId*/async deleteSignInRecordExample(recordId: number) {try {// 調用BLL層刪除記錄const rowsDeleted = await this.signInBLL.deleteSignInRecord(recordId);console.log(`刪除成功，影響行數: ${rowsDeleted}`);// 驗證刪除結果const deletedRecord = await this.signInBLL.getSignInRecordById(recordId);if (!deletedRecord) {console.log(`ID為${recordId}的簽到記錄已成功刪除`);}return 1;} catch (error) {console.error('刪除簽到記錄失敗:', error);return -1;}}/*** 完整操作流程示例*/async completeOperationFlow() {// 1. 添加一條新記錄const newRecordId = await this.addSignInRecordExample();if (newRecordId) {// 2. 查詢記錄await this.querySignInRecordsExample();// 3. 更新記錄await this.updateSignInRecordExample(newRecordId);// 4. 刪除記錄await this.deleteSignInRecordExample(newRecordId);}// 關閉數據庫（通常在應用退出時調用）// await DBHelper.getInstance().closeDB();}
}// 在Ability中使用示例
// export default class SignInAbility extends Ability {
//   onWindowStageCreate(windowStage: window.WindowStage) {
//     // 初始化示例并執行操作
//     const signInExample = new SignInExample(this.context);
//     signInExample.completeOperationFlow();
//   }
// }

調用：

/**# encoding: utf-8# 版權所有 2024 ?涂聚文有限公司# 許可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：# Author    : geovindu,Geovin Du 涂聚文.# IDE       : DevEco Studio 5.1.1# OS        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j# Datetime  : 2025/7/22 19:33# User      : geovindu# Product   : MyApplicatin# Project   : MyApplicatin# File      : Register.ets* */import router from '@ohos.router'
import promptAction from '@ohos.promptAction'
import { SignInExample } from '../Controller/SignInExample';
import { SignInRecord } from '../model/signIn';
import { Context } from '@ohos.abilityAccessCtrl';@Entry
@Component
struct Register {@State message: string = '注冊用戶';// 頁面數據@State allRecords: SignInRecord[] = [];@State employeeId: string = 'EMP001';@State employeeName: string = '張三';@State currentRecordId: number | null = null;// 頁面上下文（用于數據庫初始化）private context: Context = getContext(this) as Context;// 簽到業務實例private signInExample: SignInExample = new SignInExample(this.context);// 頁面加載時初始化數據async aboutToAppear() {await this.loadAllRecords(); // 加載所有簽到記錄}// 加載所有簽到記錄// 修正后的加載所有簽到記錄方法async loadAllRecords() {try {// 調用查詢方法并獲取結果const result = await this.signInExample.querySignInRecordsExample();// 空值判斷：如果結果為null，設置為空數組if (result === null) {this.allRecords = [];promptAction.showToast({ message: '沒有查詢到簽到記錄' });return;}// 類型判斷：確保返回的是數組if (!Array.isArray(result)) {this.allRecords = [];promptAction.showToast({ message: '數據格式錯誤' });console.error('查詢簽到記錄返回非數組類型:', result);return;}// 正常賦值this.allRecords = result;// 空數組提示if (this.allRecords.length === 0) {promptAction.showToast({ message: '當前沒有簽到記錄' });}} catch (error) {// 錯誤處理：統一捕獲并處理所有可能的異常this.allRecords = []; // 出錯時清空列表const errorMsg = error instanceof Error ? error.message : String(error);promptAction.showToast({ message: `加載失敗: ${errorMsg}` });console.error('加載簽到記錄失敗:', error);}}/*** 添加簽到記錄（綁定按鈕點擊事件）*/async handleAdd() {if (!this.employeeId || !this.employeeName) {promptAction.showToast({ message: '請輸入員工ID和姓名' });return;}try {// 生成當前時間（格式：yyyy-MM-dd HH:mm:ss）const now = new Date();const signInTime = `${now.getFullYear()}-${(now.getMonth() + 1).toString().padStart(2, '0')}-${now.getDate().toString().padStart(2, '0')} ${now.getHours().toString().padStart(2, '0')}:${now.getMinutes().toString().padStart(2, '0')}:${now.getSeconds().toString().padStart(2, '0')}`;// 創建記錄并添加const record = new SignInRecord(this.employeeId, this.employeeName, signInTime);const newId = await this.signInExample.addSignInRecordExample(); //recordpromptAction.showToast({ message: `添加成功，ID: ${newId}` });// 刷新列表await this.loadAllRecords();} catch (error) {promptAction.showToast({ message: `添加失敗: ${error.message}` });}}/*** 更新簽到記錄（綁定按鈕點擊事件）* @param record*/async handleUpdate(record: SignInRecord) {if (!record.id) {promptAction.showToast({ message: '記錄ID不存在' });return;}try {// 修改記錄（示例：在姓名后加"[已更新]"）const updatedRecord = new SignInRecord(record.employeeId,`${record.employeeName}[已更新]`,record.signInTime,record.id);// 執行更新const rows = await this.signInExample.updateSignInRecordExample(1) //(updatedRecord);if (rows > 0) {promptAction.showToast({ message: '更新成功' });await this.loadAllRecords(); // 刷新列表}} catch (error) {promptAction.showToast({ message: `更新失敗: ${error.message}` });}}/*** 刪除簽到記錄（綁定按鈕點擊事件）* @param id*/async handleDelete(id: number) {try {const rows = await this.signInExample.deleteSignInRecordExample(id);if (rows > 0) {promptAction.showToast({ message: '刪除成功' });await this.loadAllRecords(); // 刷新列表}} catch (error) {promptAction.showToast({ message: `刪除失敗: ${error.message}` });}}/*** 根據員工ID查詢（綁定按鈕點擊事件）*/async handleQueryByEmpId() {// 驗證員工ID輸入if (!this.employeeId || this.employeeId.trim() === '') {promptAction.showToast({ message: '請輸入有效的員工ID' });return;}try {// 調用BLL層方法查詢（修正方法名和調用方式）const result = await this.signInExample.querySignInRecordsExampleId(this.employeeId.trim());// 空值判斷if (result === null) {this.allRecords = [];promptAction.showToast({ message: '未查詢到相關記錄' });return;}// 類型驗證if (!Array.isArray(result)) {this.allRecords = [];promptAction.showToast({ message: '查詢數據格式錯誤' });console.error('員工簽到記錄查詢返回非數組類型:', result);return;}// 賦值并提示結果this.allRecords = result;// 根據結果數量顯示不同提示if (this.allRecords.length === 0) {promptAction.showToast({ message: `未查詢到員工${this.employeeId}的簽到記錄` });} else {promptAction.showToast({ message: `查詢到${this.allRecords.length}條記錄` });}} catch (error) {// 錯誤處理this.allRecords = [];const errorMsg = error instanceof Error ? error.message : String(error);promptAction.showToast({ message: `查詢失敗: ${errorMsg}` });console.error(`查詢員工${this.employeeId}的簽到記錄失敗:`, error);}}// 界面渲染build() {Column() {// 操作區域Column() {Text('簽到管理').fontSize(20).fontWeight(FontWeight.Bold).margin(10);// 輸入區域Row() {Button('添加簽到').onClick(() => this.handleAdd()).backgroundColor('#007DFF');Button('查詢該員工').onClick(() => this.handleQueryByEmpId()).backgroundColor('#00B42A');Button('查詢所有').onClick(() => this.loadAllRecords()).backgroundColor('#F53F3F');Button('返回').onClick(() => {router.back();}).backgroundColor('#F53F3F');}.margin(10);// 記錄列表Scroll() {List() {ForEach(this.allRecords, (record: SignInRecord) => {ListItem() {Row() {Column() {Text(`ID: ${record.id}`).fontSize(12);Text(`員工: ${record.employeeName}(${record.employeeId})`).fontSize(14);Text(`簽到時間: ${record.signInTime}`).fontSize(12);}.width('70%');Column() {Button('修改').onClick(() => this.handleUpdate(record)).width(80).margin(5).backgroundColor('#FF7D00');Button('刪除').onClick(() => this.handleDelete(record.id!)).width(80).margin(5).backgroundColor('#F53F3F');}}.padding(10);}})}}.width('100%').flexGrow(1);}.width('100%').height('100%');}.width('100%').height('100%');}
}

輸出：