(item *pb.IPItem)
| 194 | } |
| 195 | |
| 196 | func (this *SQLiteIPList) AddItem(item *pb.IPItem) error { |
| 197 | if this.isClosed { |
| 198 | return nil |
| 199 | } |
| 200 | |
| 201 | _, err := this.deleteItemStmt.Exec(item.Id) |
| 202 | if err != nil { |
| 203 | return err |
| 204 | } |
| 205 | |
| 206 | // 如果是删除，则不再创建新记录 |
| 207 | if item.IsDeleted { |
| 208 | return this.UpdateMaxVersion(item.Version) |
| 209 | } |
| 210 | |
| 211 | _, err = this.insertItemStmt.Exec(item.ListId, item.ListType, item.IsGlobal, item.Type, item.Id, item.IpFrom, item.IpTo, item.ExpiredAt, item.EventLevel, item.IsDeleted, item.Version, item.NodeId, item.ServerId) |
| 212 | if err != nil { |
| 213 | return err |
| 214 | } |
| 215 | |
| 216 | return this.UpdateMaxVersion(item.Version) |
| 217 | } |
| 218 | |
| 219 | func (this *SQLiteIPList) ReadItems(offset int64, size int64) (items []*pb.IPItem, goNext bool, err error) { |
| 220 | if this.isClosed { |