zhangqing 4 months ago
parent ec667998ff
commit 5c9b6e705d

@ -34,138 +34,200 @@ import net.micode.notes.gtask.exception.ActionFailureException;
import org.json.JSONException;
import org.json.JSONObject;
/**
* SqlData
* SQLiteJSON
*
*/
public class SqlData {
// 日志标签
private static final String TAG = SqlData.class.getSimpleName();
// 无效ID常量
private static final int INVALID_ID = -99999;
/**
*
*
*/
public static final String[] PROJECTION_DATA = new String[] {
DataColumns.ID, DataColumns.MIME_TYPE, DataColumns.CONTENT, DataColumns.DATA1,
DataColumns.DATA3
DataColumns.ID, // 数据ID
DataColumns.MIME_TYPE, // MIME类型
DataColumns.CONTENT, // 内容
DataColumns.DATA1, // 数据列1
DataColumns.DATA3 // 数据列3
};
// 数据ID列索引
public static final int DATA_ID_COLUMN = 0;
// MIME类型列索引
public static final int DATA_MIME_TYPE_COLUMN = 1;
// 内容列索引
public static final int DATA_CONTENT_COLUMN = 2;
// 数据列1索引
public static final int DATA_CONTENT_DATA_1_COLUMN = 3;
// 数据列3索引
public static final int DATA_CONTENT_DATA_3_COLUMN = 4;
// 内容解析器用于访问ContentProvider
private ContentResolver mContentResolver;
// 是否为新建数据记录
private boolean mIsCreate;
// 数据ID
private long mDataId;
// MIME类型
private String mDataMimeType;
// 内容
private String mDataContent;
// 数据列1的值
private long mDataContentData1;
// 数据列3的值
private String mDataContentData3;
// 存储有变动的数据值的ContentValues对象
private ContentValues mDiffDataValues;
/**
* -
* @param context
*/
public SqlData(Context context) {
mContentResolver = context.getContentResolver();
mIsCreate = true;
mDataId = INVALID_ID;
mDataMimeType = DataConstants.NOTE;
mDataContent = "";
mDataContentData1 = 0;
mDataContentData3 = "";
mDiffDataValues = new ContentValues();
mIsCreate = true; // 标记为新记录
mDataId = INVALID_ID; // 初始化为无效ID
mDataMimeType = DataConstants.NOTE; // 默认MIME类型为笔记
mDataContent = ""; // 内容初始化为空字符串
mDataContentData1 = 0; // 数据列1初始化为0
mDataContentData3 = ""; // 数据列3初始化为空字符串
mDiffDataValues = new ContentValues(); // 初始化差异值容器
}
/**
* -
* @param context
* @param c
*/
public SqlData(Context context, Cursor c) {
mContentResolver = context.getContentResolver();
mIsCreate = false;
loadFromCursor(c);
mDiffDataValues = new ContentValues();
mIsCreate = false; // 标记为现有记录
loadFromCursor(c); // 从游标加载数据
mDiffDataValues = new ContentValues(); // 初始化差异值容器
}
/**
*
* @param c
*/
private void loadFromCursor(Cursor c) {
mDataId = c.getLong(DATA_ID_COLUMN);
mDataMimeType = c.getString(DATA_MIME_TYPE_COLUMN);
mDataContent = c.getString(DATA_CONTENT_COLUMN);
mDataContentData1 = c.getLong(DATA_CONTENT_DATA_1_COLUMN);
mDataContentData3 = c.getString(DATA_CONTENT_DATA_3_COLUMN);
mDataId = c.getLong(DATA_ID_COLUMN); // 加载数据ID
mDataMimeType = c.getString(DATA_MIME_TYPE_COLUMN); // 加载MIME类型
mDataContent = c.getString(DATA_CONTENT_COLUMN); // 加载内容
mDataContentData1 = c.getLong(DATA_CONTENT_DATA_1_COLUMN); // 加载数据列1
mDataContentData3 = c.getString(DATA_CONTENT_DATA_3_COLUMN); // 加载数据列3
}
/**
* JSON
* JSON
* @param js JSON
* @throws JSONException JSON
*/
public void setContent(JSONObject js) throws JSONException {
// 处理数据ID
long dataId = js.has(DataColumns.ID) ? js.getLong(DataColumns.ID) : INVALID_ID;
if (mIsCreate || mDataId != dataId) {
mDiffDataValues.put(DataColumns.ID, dataId);
mDiffDataValues.put(DataColumns.ID, dataId); // 记录变化
}
mDataId = dataId;
mDataId = dataId; // 更新当前值
// 处理MIME类型
String dataMimeType = js.has(DataColumns.MIME_TYPE) ? js.getString(DataColumns.MIME_TYPE)
: DataConstants.NOTE;
if (mIsCreate || !mDataMimeType.equals(dataMimeType)) {
mDiffDataValues.put(DataColumns.MIME_TYPE, dataMimeType);
mDiffDataValues.put(DataColumns.MIME_TYPE, dataMimeType); // 记录变化
}
mDataMimeType = dataMimeType;
mDataMimeType = dataMimeType; // 更新当前值
// 处理内容
String dataContent = js.has(DataColumns.CONTENT) ? js.getString(DataColumns.CONTENT) : "";
if (mIsCreate || !mDataContent.equals(dataContent)) {
mDiffDataValues.put(DataColumns.CONTENT, dataContent);
mDiffDataValues.put(DataColumns.CONTENT, dataContent); // 记录变化
}
mDataContent = dataContent;
mDataContent = dataContent; // 更新当前值
// 处理数据列1
long dataContentData1 = js.has(DataColumns.DATA1) ? js.getLong(DataColumns.DATA1) : 0;
if (mIsCreate || mDataContentData1 != dataContentData1) {
mDiffDataValues.put(DataColumns.DATA1, dataContentData1);
mDiffDataValues.put(DataColumns.DATA1, dataContentData1); // 记录变化
}
mDataContentData1 = dataContentData1;
mDataContentData1 = dataContentData1; // 更新当前值
// 处理数据列3
String dataContentData3 = js.has(DataColumns.DATA3) ? js.getString(DataColumns.DATA3) : "";
if (mIsCreate || !mDataContentData3.equals(dataContentData3)) {
mDiffDataValues.put(DataColumns.DATA3, dataContentData3);
mDiffDataValues.put(DataColumns.DATA3, dataContentData3); // 记录变化
}
mDataContentData3 = dataContentData3;
mDataContentData3 = dataContentData3; // 更新当前值
}
/**
* JSON
* @return JSON
* @throws JSONException JSON
*/
public JSONObject getContent() throws JSONException {
if (mIsCreate) {
Log.e(TAG, "it seems that we haven't created this in database yet");
return null;
}
JSONObject js = new JSONObject();
js.put(DataColumns.ID, mDataId);
js.put(DataColumns.MIME_TYPE, mDataMimeType);
js.put(DataColumns.CONTENT, mDataContent);
js.put(DataColumns.DATA1, mDataContentData1);
js.put(DataColumns.DATA3, mDataContentData3);
js.put(DataColumns.ID, mDataId); // 添加数据ID
js.put(DataColumns.MIME_TYPE, mDataMimeType); // 添加MIME类型
js.put(DataColumns.CONTENT, mDataContent); // 添加内容
js.put(DataColumns.DATA1, mDataContentData1); // 添加数据列1
js.put(DataColumns.DATA3, mDataContentData3); // 添加数据列3
return js;
}
/**
*
*
* @param noteId ID
* @param validateVersion
* @param version
*/
public void commit(long noteId, boolean validateVersion, long version) {
if (mIsCreate) {
// 新记录:插入操作
if (mDataId == INVALID_ID && mDiffDataValues.containsKey(DataColumns.ID)) {
mDiffDataValues.remove(DataColumns.ID);
mDiffDataValues.remove(DataColumns.ID); // 移除无效ID
}
mDiffDataValues.put(DataColumns.NOTE_ID, noteId);
Uri uri = mContentResolver.insert(Notes.CONTENT_DATA_URI, mDiffDataValues);
mDiffDataValues.put(DataColumns.NOTE_ID, noteId); // 添加笔记ID
Uri uri = mContentResolver.insert(Notes.CONTENT_DATA_URI, mDiffDataValues); // 插入数据
try {
// 从返回的URI中提取新记录的ID
mDataId = Long.valueOf(uri.getPathSegments().get(1));
} catch (NumberFormatException e) {
Log.e(TAG, "Get note id error :" + e.toString());
throw new ActionFailureException("create note failed");
}
} else {
// 现有记录:更新操作
if (mDiffDataValues.size() > 0) {
int result = 0;
if (!validateVersion) {
// 不验证版本号:直接更新
result = mContentResolver.update(ContentUris.withAppendedId(
Notes.CONTENT_DATA_URI, mDataId), mDiffDataValues, null, null);
} else {
// 验证版本号:确保版本匹配
result = mContentResolver.update(ContentUris.withAppendedId(
Notes.CONTENT_DATA_URI, mDataId), mDiffDataValues,
" ? in (SELECT " + NoteColumns.ID + " FROM " + TABLE.NOTE
@ -179,11 +241,16 @@ public class SqlData {
}
}
mDiffDataValues.clear();
mIsCreate = false;
// 重置状态
mDiffDataValues.clear(); // 清空差异值
mIsCreate = false; // 标记为现有记录
}
/**
* ID
* @return ID
*/
public long getId() {
return mDataId;
}
}
}
Loading…
Cancel
Save