/** 数据库实例 */
static FMDatabase *_db;
//初始化时候就行先进行数据库的创建 这是自己自动调用
+ (void)initialize
{
// 1.获得数据库文件的路径
NSString *doc = [NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) lastObject];
NSString *filename = [doc stringByAppendingPathComponent:@"status.sqlite"];
// 2.得到数据库
_db = [FMDatabase databaseWithPath:filename];
// 3.打开数据库
if ([_db open])
{
// 4.创表
BOOL result = [_db executeUpdate:@"CREATE
TABLE IF NOT EXISTS t_home_status (id integer PRIMARY KEY AUTOINCREMENT, access_token text NOT NULL, status_idstr text NOT NULL, status_dict blob NOT NULL);"];
if (result) {
NSLog(@"成功创表");
} else {
NSLog(@"创表失败");
}
}
}
+ (void)homeStatusesWithParam:(HMHomeStatusesParam *)param
success:(void (^)(HMHomeStatusesResult *))success failure:(void (^)(NSError *))failure
{
// param.count = @5;
// 从数据库中读取（加载）缓存数据(微博模型数组)
NSArray *cachedHomeStatuses = [self cachedHomeStatusesWithParam:param];
if (cachedHomeStatuses.count != 0)
{ // 有缓存数据
if (success) {
HMHomeStatusesResult *result = [[HMHomeStatusesResult alloc] init];
result.statuses = cachedHomeStatuses;
success(result);
}
} else { // 没有缓存数据
NSDictionary *params = [param keyValues];
[HMHttpTool get:@"https://api.weibo.com/2/statuses/home_timeline.json" params:params success:^(id responseObj)
{
// 新浪返回的字典数组
NSArray *statusDictArray = responseObj[@"statuses"];
// 缓存微博字典数组
[self saveHomeStatusDictArray:statusDictArray accessToken:param.access_token];
if (success) {
HMHomeStatusesResult *result = [HMHomeStatusesResult objectWithKeyValues:responseObj];
success(result);
}
} failure:^(NSError *error)
{
if (failure) {
failure(error);
}
}];
}
}
/**
* 通过请求参数去数据库中加载对应的微博数据
*
* @param param 请求参数
*/
+ (NSArray *)cachedHomeStatusesWithParam:(HMHomeStatusesParam *)param
{
// 创建数组缓存微博数据
NSMutableArray *statuses = [NSMutableArray array];
// 根据请求参数查询数据
FMResultSet *resultSet = nil;
if (param.since_id)
{
resultSet = [_db executeQuery:@"SELECT
* FROM t_home_status WHERE access_token = ? AND status_idstr > ? ORDER BY status_idstr DESC limit ?;", param.access_token,
param.since_id, param.count];
} else if (param.max_id)
{
resultSet = [_db executeQuery:@"SELECT
* FROM t_home_status WHERE access_token = ? AND status_idstr <= ? ORDER BY status_idstr DESC limit ?;", param.access_token,
param.max_id, param.count];
} else {
resultSet = [_db executeQuery:@"SELECT
* FROM t_home_status WHERE access_token = ? ORDER BY status_idstr DESC limit ?;", param.access_token, param.count];
}
// 遍历查询结果
while (resultSet.next)
{
NSData *statusDictData = [resultSet objectForColumnName:@"status_dict"];
NSDictionary *statusDict = [NSKeyedUnarchiver unarchiveObjectWithData:statusDictData];
// 字典转模型
HMStatus *status = [HMStatus objectWithKeyValues:statusDict];
// 添加模型到数组中
[statuses addObject:status];
}
return statuses;
}
/**
* 缓存微博字典数组到数据库中
*/
+ (void)saveHomeStatusDictArray:(NSArray *)statusDictArray
accessToken:(NSString *)accessToken
{
for (NSDictionary *statusDict in statusDictArray)
{
// 把statusDict字典对象序列化成NSData二进制数据
NSData *data = [NSKeyedArchiver archivedDataWithRootObject:statusDict];
[_db executeUpdate:@"INSERT
INTO t_home_status (access_token, status_idstr, status_dict) VALUES (?, ?, ?);",
accessToken, statusDict[@"idstr"], data];
}
}