db

package
v3.8.3-patch.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 7, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DataBase 

type DataBase struct {
	// contains filtered or unexported fields
}

func NewDataBase 

func NewDataBase(ctx context.Context, loginUserID string, dbDir string, logLevel int) (*DataBase, error)

func (*DataBase) BatchInsertConversationList 

func (d *DataBase) BatchInsertConversationList(ctx context.Context, conversationList []*model_struct.LocalConversation) error

func (*DataBase) BatchInsertConversationUnreadMessageList 

func (d *DataBase) BatchInsertConversationUnreadMessageList(ctx context.Context, messageList []*model_struct.LocalConversationUnreadMessage) error

func (*DataBase) BatchInsertFriend added in v3.8.0 

func (d *DataBase) BatchInsertFriend(ctx context.Context, friendList []*model_struct.LocalFriend) error

func (*DataBase) BatchInsertGroup added in v3.8.0 

func (d *DataBase) BatchInsertGroup(ctx context.Context, groupList []*model_struct.LocalGroup) error

func (*DataBase) BatchInsertGroupMember 

func (d *DataBase) BatchInsertGroupMember(ctx context.Context, groupMemberList []*model_struct.LocalGroupMember) error

func (*DataBase) BatchInsertMessageList 

func (d *DataBase) BatchInsertMessageList(ctx context.Context, conversationID string, MessageList []*model_struct.LocalChatLog) error

func (*DataBase) BatchInsertNotificationSeq added in v3.8.0 

func (d *DataBase) BatchInsertNotificationSeq(ctx context.Context, notificationSeqs []*model_struct.NotificationSeqs) error

func (*DataBase) BatchUpdateConversationList 

func (d *DataBase) BatchUpdateConversationList(ctx context.Context, conversationList []*model_struct.LocalConversation) error

func (*DataBase) CheckConversationNormalMsgSeq added in v3.8.0 

func (d *DataBase) CheckConversationNormalMsgSeq(ctx context.Context, conversationID string) (int64, error)

func (*DataBase) ClearConversation 

func (d *DataBase) ClearConversation(ctx context.Context, conversationID string) error

Clear the conversation, which is used to delete the conversation history message and clear the conversation at the same time. The GetAllConversation or GetConversationListSplit interface can still be obtained, but there is no latest message.

func (*DataBase) Close 

func (d *DataBase) Close(ctx context.Context) error

func (*DataBase) ConversationIfExists 

func (d *DataBase) ConversationIfExists(ctx context.Context, conversationID string) (bool, error)

func (*DataBase) DecrConversationUnreadCount 

func (d *DataBase) DecrConversationUnreadCount(ctx context.Context, conversationID string, count int64) (err error)

func (*DataBase) DeleteAdminGroupRequest 

func (d *DataBase) DeleteAdminGroupRequest(ctx context.Context, groupID, userID string) error

func (*DataBase) DeleteAllConversation added in v3.8.0 

func (d *DataBase) DeleteAllConversation(ctx context.Context) error

func (*DataBase) DeleteAllFriend added in v3.8.0 

func (d *DataBase) DeleteAllFriend(ctx context.Context) error

func (*DataBase) DeleteAllGroup added in v3.8.0 

func (d *DataBase) DeleteAllGroup(ctx context.Context) error

func (*DataBase) DeleteBlack 

func (d *DataBase) DeleteBlack(ctx context.Context, blockUserID string) error

func (*DataBase) DeleteConversation 

func (d *DataBase) DeleteConversation(ctx context.Context, conversationID string) error

func (*DataBase) DeleteConversationAllMessages 

func (d *DataBase) DeleteConversationAllMessages(ctx context.Context, conversationID string) error

func (*DataBase) DeleteConversationMsgs 

func (d *DataBase) DeleteConversationMsgs(ctx context.Context, conversationID string, msgIDs []string) error

func (*DataBase) DeleteConversationMsgsBySeqs 

func (d *DataBase) DeleteConversationMsgsBySeqs(ctx context.Context, conversationID string, seqs []int64) error

func (*DataBase) DeleteConversationUnreadMessageList 

func (d *DataBase) DeleteConversationUnreadMessageList(ctx context.Context, conversationID string, sendTime int64) int64

func (*DataBase) DeleteExpireUpload 

func (d *DataBase) DeleteExpireUpload(ctx context.Context) error

func (*DataBase) DeleteFriendDB 

func (d *DataBase) DeleteFriendDB(ctx context.Context, friendUserID string) error

func (*DataBase) DeleteFriendRequestBothUserID 

func (d *DataBase) DeleteFriendRequestBothUserID(ctx context.Context, fromUserID, toUserID string) error

func (*DataBase) DeleteGroup 

func (d *DataBase) DeleteGroup(ctx context.Context, groupID string) error

func (*DataBase) DeleteGroupAllMembers 

func (d *DataBase) DeleteGroupAllMembers(ctx context.Context, groupID string) error

func (*DataBase) DeleteGroupMember 

func (d *DataBase) DeleteGroupMember(ctx context.Context, groupID, userID string) error

func (*DataBase) DeleteGroupRequest 

func (d *DataBase) DeleteGroupRequest(ctx context.Context, groupID, userID string) error

func (*DataBase) DeleteSendingMessage added in v3.4.0 

func (d *DataBase) DeleteSendingMessage(ctx context.Context, conversationID, clientMsgID string) error

func (*DataBase) DeleteUpload 

func (d *DataBase) DeleteUpload(ctx context.Context, partHash string) error

func (*DataBase) DeleteVersionSync added in v3.8.0 

func (d *DataBase) DeleteVersionSync(ctx context.Context, tableName, entityID string) error

func (*DataBase) FindAllConversationConversationID 

func (d *DataBase) FindAllConversationConversationID(ctx context.Context) (conversationIDs []string, err error)

func (*DataBase) FindAllUnreadConversationConversationID added in v3.8.2 

func (d *DataBase) FindAllUnreadConversationConversationID(ctx context.Context) (conversationIDs []string, err error)

func (*DataBase) GetAdminGroupApplication 

func (d *DataBase) GetAdminGroupApplication(ctx context.Context) ([]*model_struct.LocalAdminGroupRequest, error)

func (*DataBase) GetAllConversationIDList 

func (d *DataBase) GetAllConversationIDList(ctx context.Context) (result []string, err error)

func (*DataBase) GetAllConversationListDB 

func (d *DataBase) GetAllConversationListDB(ctx context.Context) ([]*model_struct.LocalConversation, error)

func (*DataBase) GetAllConversations 

func (d *DataBase) GetAllConversations(ctx context.Context) ([]*model_struct.LocalConversation, error)

func (*DataBase) GetAllFriendList 

func (d *DataBase) GetAllFriendList(ctx context.Context) ([]*model_struct.LocalFriend, error)

func (*DataBase) GetAllGroupInfoByGroupIDOrGroupName 

func (d *DataBase) GetAllGroupInfoByGroupIDOrGroupName(ctx context.Context, keyword string, isSearchGroupID bool, isSearchGroupName bool) ([]*model_struct.LocalGroup, error)

func (*DataBase) GetAllGroupMemberList 

func (d *DataBase) GetAllGroupMemberList(ctx context.Context) ([]model_struct.LocalGroupMember, error)

func (*DataBase) GetAllSendingMessages added in v3.4.0 

func (d *DataBase) GetAllSendingMessages(ctx context.Context) (friendRequests []*model_struct.LocalSendingMessages, err error)

func (*DataBase) GetAllSingleConversationIDList 

func (d *DataBase) GetAllSingleConversationIDList(ctx context.Context) (result []string, err error)

func (*DataBase) GetAppSDKVersion added in v3.8.0 

func (d *DataBase) GetAppSDKVersion(ctx context.Context) (*model_struct.LocalAppSDKVersion, error)

func (*DataBase) GetBlackInfoByBlockUserID 

func (d *DataBase) GetBlackInfoByBlockUserID(ctx context.Context, blockUserID string) (*model_struct.LocalBlack, error)

func (*DataBase) GetBlackInfoList 

func (d *DataBase) GetBlackInfoList(ctx context.Context, blockUserIDList []string) ([]*model_struct.LocalBlack, error)

func (*DataBase) GetBlackListDB 

func (d *DataBase) GetBlackListDB(ctx context.Context) ([]*model_struct.LocalBlack, error)

func (*DataBase) GetBlackListUserID 

func (d *DataBase) GetBlackListUserID(ctx context.Context) (blackListUid []string, err error)

func (*DataBase) GetBothFriendReq 

func (d *DataBase) GetBothFriendReq(ctx context.Context, fromUserID, toUserID string) (friendRequests []*model_struct.LocalFriendRequest, err error)

func (*DataBase) GetConversation 

func (d *DataBase) GetConversation(ctx context.Context, conversationID string) (*model_struct.LocalConversation, error)

func (*DataBase) GetConversationByUserID 

func (d *DataBase) GetConversationByUserID(ctx context.Context, userID string) (*model_struct.LocalConversation, error)

func (*DataBase) GetConversationListSplitDB 

func (d *DataBase) GetConversationListSplitDB(ctx context.Context, offset, count int) ([]*model_struct.LocalConversation, error)

func (*DataBase) GetConversationNormalMsgSeq 

func (d *DataBase) GetConversationNormalMsgSeq(ctx context.Context, conversationID string) (int64, error)

func (*DataBase) GetConversationPeerNormalMsgSeq 

func (d *DataBase) GetConversationPeerNormalMsgSeq(ctx context.Context, conversationID string) (int64, error)

func (*DataBase) GetExistTables added in v3.8.0 

func (d *DataBase) GetExistTables(ctx context.Context) ([]string, error)

func (*DataBase) GetFriendApplicationByBothID 

func (d *DataBase) GetFriendApplicationByBothID(ctx context.Context, fromUserID, toUserID string) (*model_struct.LocalFriendRequest, error)

func (*DataBase) GetFriendInfoByFriendUserID 

func (d *DataBase) GetFriendInfoByFriendUserID(ctx context.Context, FriendUserID string) (*model_struct.LocalFriend, error)

func (*DataBase) GetFriendInfoList 

func (d *DataBase) GetFriendInfoList(ctx context.Context, friendUserIDList []string) ([]*model_struct.LocalFriend, error)

func (*DataBase) GetFriendListCount added in v3.8.0 

func (d *DataBase) GetFriendListCount(ctx context.Context) (int64, error)

func (*DataBase) GetGroupInfoByGroupID 

func (d *DataBase) GetGroupInfoByGroupID(ctx context.Context, groupID string) (*model_struct.LocalGroup, error)

func (*DataBase) GetGroupMemberCount 

func (d *DataBase) GetGroupMemberCount(ctx context.Context, groupID string) (int32, error)

func (*DataBase) GetGroupMemberInfoByGroupIDUserID 

func (d *DataBase) GetGroupMemberInfoByGroupIDUserID(ctx context.Context, groupID, userID string) (*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberListByGroupID 

func (d *DataBase) GetGroupMemberListByGroupID(ctx context.Context, groupID string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberListByUserIDs added in v3.8.0 

func (d *DataBase) GetGroupMemberListByUserIDs(ctx context.Context, groupID string, filter int32, userIDs []string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberListSplit 

func (d *DataBase) GetGroupMemberListSplit(ctx context.Context, groupID string, filter int32, offset, count int) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberListSplitByJoinTimeFilter 

func (d *DataBase) GetGroupMemberListSplitByJoinTimeFilter(ctx context.Context, groupID string, offset, count int, joinTimeBegin, joinTimeEnd int64, userIDList []string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberOwnerAndAdminDB 

func (d *DataBase) GetGroupMemberOwnerAndAdminDB(ctx context.Context, groupID string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMinSeq 

func (d *DataBase) GetGroupMinSeq(ctx context.Context, groupID string) (uint32, error)

func (*DataBase) GetGroupSomeMemberInfo 

func (d *DataBase) GetGroupSomeMemberInfo(ctx context.Context, groupID string, userIDList []string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroups 

func (d *DataBase) GetGroups(ctx context.Context, groupIDs []string) ([]*model_struct.LocalGroup, error)

func (*DataBase) GetHiddenConversationList 

func (d *DataBase) GetHiddenConversationList(ctx context.Context) ([]*model_struct.LocalConversation, error)

func (*DataBase) GetJoinedGroupListDB 

func (d *DataBase) GetJoinedGroupListDB(ctx context.Context) ([]*model_struct.LocalGroup, error)

func (*DataBase) GetLatestActiveMessage added in v3.8.1 

func (d *DataBase) GetLatestActiveMessage(ctx context.Context, conversationID string, isReverse bool) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) GetLatestValidServerMessage added in v3.8.3 

func (d *DataBase) GetLatestValidServerMessage(ctx context.Context, conversationID string, startTime int64, isReverse bool) (*model_struct.LocalChatLog, error)

func (*DataBase) GetLoginUser 

func (d *DataBase) GetLoginUser(ctx context.Context, userID string) (*model_struct.LocalUser, error)

func (*DataBase) GetMessage 

func (d *DataBase) GetMessage(ctx context.Context, conversationID string, clientMsgID string) (*model_struct.LocalChatLog, error)

func (*DataBase) GetMessageBySeq 

func (d *DataBase) GetMessageBySeq(ctx context.Context, conversationID string, seq int64) (*model_struct.LocalChatLog, error)

func (*DataBase) GetMessageList 

func (d *DataBase) GetMessageList(ctx context.Context, conversationID string, count int, startTime, startSeq int64, startClientMsgID string, isReverse bool) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) GetMessagesByClientMsgIDs 

func (d *DataBase) GetMessagesByClientMsgIDs(ctx context.Context, conversationID string, msgIDs []string) (msgs []*model_struct.LocalChatLog, err error)

func (*DataBase) GetMessagesBySeqs 

func (d *DataBase) GetMessagesBySeqs(ctx context.Context, conversationID string, seqs []int64) (msgs []*model_struct.LocalChatLog, err error)

func (*DataBase) GetMinSeq 

func (d *DataBase) GetMinSeq(ctx context.Context, ID string) (uint32, error)

func (*DataBase) GetMultipleConversationDB 

func (d *DataBase) GetMultipleConversationDB(ctx context.Context, conversationIDList []string) (result []*model_struct.LocalConversation, err error)

func (*DataBase) GetNotificationAllSeqs 

func (d *DataBase) GetNotificationAllSeqs(ctx context.Context) ([]*model_struct.NotificationSeqs, error)

func (*DataBase) GetPageFriendList 

func (d *DataBase) GetPageFriendList(ctx context.Context, offset, count int) ([]*model_struct.LocalFriend, error)

func (*DataBase) GetRecvFriendApplication 

func (d *DataBase) GetRecvFriendApplication(ctx context.Context) ([]*model_struct.LocalFriendRequest, error)

func (*DataBase) GetSendFriendApplication 

func (d *DataBase) GetSendFriendApplication(ctx context.Context) ([]*model_struct.LocalFriendRequest, error)

func (*DataBase) GetSendGroupApplication 

func (d *DataBase) GetSendGroupApplication(ctx context.Context) ([]*model_struct.LocalGroupRequest, error)

func (*DataBase) GetTotalUnreadMsgCountDB 

func (d *DataBase) GetTotalUnreadMsgCountDB(ctx context.Context) (totalUnreadCount int32, err error)

func (*DataBase) GetUnreadMessage 

func (d *DataBase) GetUnreadMessage(ctx context.Context, conversationID string) (msgs []*model_struct.LocalChatLog, err error)

func (*DataBase) GetUpload 

func (d *DataBase) GetUpload(ctx context.Context, partHash string) (*model_struct.LocalUpload, error)

func (*DataBase) GetUserMinSeq 

func (d *DataBase) GetUserMinSeq(ctx context.Context) (uint32, error)

func (*DataBase) GetVersionSync added in v3.8.0 

func (d *DataBase) GetVersionSync(ctx context.Context, tableName, entityID string) (*model_struct.LocalVersionSync, error)

func (*DataBase) IncrConversationUnreadCount 

func (d *DataBase) IncrConversationUnreadCount(ctx context.Context, conversationID string) error

func (*DataBase) InitDB 

func (d *DataBase) InitDB(ctx context.Context, userID string, dataDir string) error

func (*DataBase) InsertAdminGroupRequest 

func (d *DataBase) InsertAdminGroupRequest(ctx context.Context, groupRequest *model_struct.LocalAdminGroupRequest) error

func (*DataBase) InsertBlack 

func (d *DataBase) InsertBlack(ctx context.Context, black *model_struct.LocalBlack) error

func (*DataBase) InsertConversation 

func (d *DataBase) InsertConversation(ctx context.Context, conversationList *model_struct.LocalConversation) error

func (*DataBase) InsertFriend 

func (d *DataBase) InsertFriend(ctx context.Context, friend *model_struct.LocalFriend) error

func (*DataBase) InsertFriendRequest 

func (d *DataBase) InsertFriendRequest(ctx context.Context, friendRequest *model_struct.LocalFriendRequest) error

func (*DataBase) InsertGroup 

func (d *DataBase) InsertGroup(ctx context.Context, groupInfo *model_struct.LocalGroup) error

func (*DataBase) InsertGroupMember 

func (d *DataBase) InsertGroupMember(ctx context.Context, groupMember *model_struct.LocalGroupMember) error

func (*DataBase) InsertGroupRequest 

func (d *DataBase) InsertGroupRequest(ctx context.Context, groupRequest *model_struct.LocalGroupRequest) error

func (*DataBase) InsertLoginUser 

func (d *DataBase) InsertLoginUser(ctx context.Context, user *model_struct.LocalUser) error

func (*DataBase) InsertMessage 

func (d *DataBase) InsertMessage(ctx context.Context, conversationID string, Message *model_struct.LocalChatLog) error

func (*DataBase) InsertSendingMessage added in v3.4.0 

func (d *DataBase) InsertSendingMessage(ctx context.Context, message *model_struct.LocalSendingMessages) error

func (*DataBase) InsertUpload 

func (d *DataBase) InsertUpload(ctx context.Context, upload *model_struct.LocalUpload) error

func (*DataBase) MarkConversationAllMessageAsRead 

func (d *DataBase) MarkConversationAllMessageAsRead(ctx context.Context, conversationID string) (rowsAffected int64, err error)

func (*DataBase) MarkConversationMessageAsReadBySeqs 

func (d *DataBase) MarkConversationMessageAsReadBySeqs(ctx context.Context, conversationID string, seqs []int64) (rowsAffected int64, err error)

func (*DataBase) MarkConversationMessageAsReadDB 

func (d *DataBase) MarkConversationMessageAsReadDB(ctx context.Context, conversationID string, msgIDs []string) (rowsAffected int64, err error)

func (*DataBase) MarkDeleteConversationAllMessages 

func (d *DataBase) MarkDeleteConversationAllMessages(ctx context.Context, conversationID string) error

func (*DataBase) ProcessUserCommandAdd added in v3.8.0 

func (d *DataBase) ProcessUserCommandAdd(ctx context.Context, command *model_struct.LocalUserCommand) error

ProcessUserCommandAdd adds a new user command to the database.

func (*DataBase) ProcessUserCommandDelete added in v3.8.0 

func (d *DataBase) ProcessUserCommandDelete(ctx context.Context, command *model_struct.LocalUserCommand) error

ProcessUserCommandDelete deletes a user command from the database.

func (*DataBase) ProcessUserCommandGetAll added in v3.8.0 

func (d *DataBase) ProcessUserCommandGetAll(ctx context.Context) ([]*model_struct.LocalUserCommand, error)

ProcessUserCommandGetAll retrieves user commands from the database.

func (*DataBase) ProcessUserCommandUpdate added in v3.8.0 

func (d *DataBase) ProcessUserCommandUpdate(ctx context.Context, command *model_struct.LocalUserCommand) error

ProcessUserCommandUpdate updates an existing user command in the database.

func (*DataBase) RemoveConversationDraft 

func (d *DataBase) RemoveConversationDraft(ctx context.Context, conversationID, draftText string) error

func (*DataBase) ResetAllConversation 

func (d *DataBase) ResetAllConversation(ctx context.Context) error

ResetAllConversation Reset ALL conversation is equivalent to deleting the conversation, and the GetAllConversation or GetConversationListSplit interface will no longer be obtained.

func (*DataBase) ResetConversation 

func (d *DataBase) ResetConversation(ctx context.Context, conversationID string) error

Reset the conversation is equivalent to deleting the conversation, and the GetAllConversation or GetConversationListSplit interface will no longer be obtained.

func (*DataBase) SearchAllMessageByContentType 

func (d *DataBase) SearchAllMessageByContentType(ctx context.Context, conversationID string, contentType int) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SearchConversations added in v3.5.0 

func (d *DataBase) SearchConversations(ctx context.Context, searchParam string) ([]*model_struct.LocalConversation, error)

func (*DataBase) SearchFriendList 

func (d *DataBase) SearchFriendList(ctx context.Context, keyword string, isSearchUserID, isSearchNickname, isSearchRemark bool) ([]*model_struct.LocalFriend, error)

func (*DataBase) SearchGroupMembersDB 

func (d *DataBase) SearchGroupMembersDB(ctx context.Context, keyword string, groupID string, isSearchMemberNickname, isSearchUserID bool, offset, count int) (result []*model_struct.LocalGroupMember, err error)

func (*DataBase) SearchMessageByContentType 

func (d *DataBase) SearchMessageByContentType(ctx context.Context, contentType []int, conversationID string, startTime, endTime int64, offset, count int) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SearchMessageByContentTypeAndKeyword 

func (d *DataBase) SearchMessageByContentTypeAndKeyword(ctx context.Context, contentType []int, conversationID string, keywordList []string, keywordListMatchType int, startTime, endTime int64) (result []*model_struct.LocalChatLog, err error)

SearchMessageByContentTypeAndKeyword searches for messages in the database that match specified content types and keywords within a given time range.

func (*DataBase) SearchMessageByKeyword 

func (d *DataBase) SearchMessageByKeyword(ctx context.Context, contentType []int, keywordList []string, keywordListMatchType int, conversationID string, startTime, endTime int64, offset, count int) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SetAppSDKVersion added in v3.8.0 

func (d *DataBase) SetAppSDKVersion(ctx context.Context, appVersion *model_struct.LocalAppSDKVersion) error

func (*DataBase) SetConversationDraftDB 

func (d *DataBase) SetConversationDraftDB(ctx context.Context, conversationID, draftText string) error

func (*DataBase) SetMinSeq 

func (d *DataBase) SetMinSeq(ctx context.Context, ID string, minSeq uint32) error

func (*DataBase) SetMultipleConversationRecvMsgOpt 

func (d *DataBase) SetMultipleConversationRecvMsgOpt(ctx context.Context, conversationIDList []string, opt int) (err error)

func (*DataBase) SetNotificationSeq 

func (d *DataBase) SetNotificationSeq(ctx context.Context, conversationID string, seq int64) error

func (*DataBase) SetVersionSync added in v3.8.0 

func (d *DataBase) SetVersionSync(ctx context.Context, lv *model_struct.LocalVersionSync) error

func (*DataBase) UnPinConversation 

func (d *DataBase) UnPinConversation(ctx context.Context, conversationID string, isPinned int) error

func (*DataBase) UpdateAdminGroupRequest 

func (d *DataBase) UpdateAdminGroupRequest(ctx context.Context, groupRequest *model_struct.LocalAdminGroupRequest) error

func (*DataBase) UpdateAllConversation 

func (d *DataBase) UpdateAllConversation(ctx context.Context, conversation *model_struct.LocalConversation) error

func (*DataBase) UpdateBlack 

func (d *DataBase) UpdateBlack(ctx context.Context, black *model_struct.LocalBlack) error

func (*DataBase) UpdateColumnsConversation 

func (d *DataBase) UpdateColumnsConversation(ctx context.Context, conversationID string, args map[string]interface{}) error

func (*DataBase) UpdateColumnsFriend added in v3.5.0 

func (d *DataBase) UpdateColumnsFriend(ctx context.Context, friendIDs []string, args map[string]interface{}) error

func (*DataBase) UpdateColumnsMessage 

func (d *DataBase) UpdateColumnsMessage(ctx context.Context, conversationID, ClientMsgID string, args map[string]interface{}) error

func (*DataBase) UpdateConversation 

func (d *DataBase) UpdateConversation(ctx context.Context, c *model_struct.LocalConversation) error

func (*DataBase) UpdateConversationForSync 

func (d *DataBase) UpdateConversationForSync(ctx context.Context, c *model_struct.LocalConversation) error

func (*DataBase) UpdateFriend 

func (d *DataBase) UpdateFriend(ctx context.Context, friend *model_struct.LocalFriend) error

func (*DataBase) UpdateFriendRequest 

func (d *DataBase) UpdateFriendRequest(ctx context.Context, friendRequest *model_struct.LocalFriendRequest) error

func (*DataBase) UpdateGroup 

func (d *DataBase) UpdateGroup(ctx context.Context, groupInfo *model_struct.LocalGroup) error

func (*DataBase) UpdateGroupMember 

func (d *DataBase) UpdateGroupMember(ctx context.Context, groupMember *model_struct.LocalGroupMember) error

func (*DataBase) UpdateGroupRequest 

func (d *DataBase) UpdateGroupRequest(ctx context.Context, groupRequest *model_struct.LocalGroupRequest) error

func (*DataBase) UpdateLoginUser 

func (d *DataBase) UpdateLoginUser(ctx context.Context, user *model_struct.LocalUser) error

func (*DataBase) UpdateLoginUserByMap 

func (d *DataBase) UpdateLoginUserByMap(ctx context.Context, user *model_struct.LocalUser, args map[string]interface{}) error

func (*DataBase) UpdateMessage 

func (d *DataBase) UpdateMessage(ctx context.Context, conversationID string, c *model_struct.LocalChatLog) error

func (*DataBase) UpdateMessageBySeq 

func (d *DataBase) UpdateMessageBySeq(ctx context.Context, conversationID string, c *model_struct.LocalChatLog) error

func (*DataBase) UpdateMessageTimeAndStatus 

func (d *DataBase) UpdateMessageTimeAndStatus(ctx context.Context, conversationID, clientMsgID string, serverMsgID string, sendTime int64, status int32) error

func (*DataBase) UpdateMsgSenderFaceURL 

func (d *DataBase) UpdateMsgSenderFaceURL(ctx context.Context, sendID, faceURL string, sType int) error

func (*DataBase) UpdateMsgSenderFaceURLAndSenderNickname 

func (d *DataBase) UpdateMsgSenderFaceURLAndSenderNickname(ctx context.Context, conversationID, sendID, faceURL, nickname string) error

func (*DataBase) UpdateOrCreateConversations 

func (d *DataBase) UpdateOrCreateConversations(ctx context.Context, conversationList []*model_struct.LocalConversation) error

func (*DataBase) UpdateUpload 

func (d *DataBase) UpdateUpload(ctx context.Context, upload *model_struct.LocalUpload) error

type TableChecker added in v3.8.0 

type TableChecker struct {
	// contains filtered or unexported fields
}

func NewTableChecker added in v3.8.0 

func NewTableChecker(tables []string) *TableChecker

func (*TableChecker) HasTable added in v3.8.0 

func (tc *TableChecker) HasTable(tableName string) bool

func (*TableChecker) InitTableCache added in v3.8.0 

func (tc *TableChecker) InitTableCache(tables []string)

func (*TableChecker) UpdateTable added in v3.8.0 

func (tc *TableChecker) UpdateTable(tableName string)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.