DAO (4q1btr) - PasteCode.io

DAO

hacker98

Publica year ago5 Snippets

SentRequestDAO

plain_texta year ago

package com.example.chatappdemo.DAO;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.util.Log;

import com.example.chatappdemo.DatabaseHelper;
import com.example.chatappdemo.model.SentRequest;

import java.util.ArrayList;
import java.util.List;

public class SentRequestDAO {
    private SQLiteDatabase db;
    private SQLiteOpenHelper dbHelper;

    // Constructor
    public SentRequestDAO(Context context) {
        dbHelper = new DatabaseHelper(context);
    }

    // Mở kết nối
    private void open() throws SQLException {
        db = dbHelper.getWritableDatabase();
    }

    // Đóng kết nối
    private void close() {
        if (db != null && db.isOpen()) {
            db.close();
        }
    }

    // Thêm dữ liệu vào bảng sent_request
    public long insertSentRequest(SentRequest sentRequest) {
        open();
        ContentValues values = new ContentValues();
        values.put("IPSent", sentRequest.getIPSent());
        values.put("name", sentRequest.getName());
        values.put("status", sentRequest.getStatus());
        long result = 0;
        try {
            result = db.insert("SentRequest", null, values);
        } catch (SQLException e) {
            e.printStackTrace();
            Log.d("SentRequestDAO", e.getMessage());
        }
        close();
        return result;
    }

    // Cập nhật dữ liệu trong bảng sent_request
    public int updateSentRequest(SentRequest sentRequest) {
        open();
        ContentValues values = new ContentValues();
        values.put("IPSent", sentRequest.getIPSent());
        values.put("name", sentRequest.getName());
        values.put("status", sentRequest.getStatus());

        int result = db.update("SentRequest", values, "IPSent = ?", new String[]{sentRequest.getIPSent()});
        close();
        return result;
    }

    // Lấy dữ liệu từ bảng sent_request theo IP_sent
    public SentRequest getSentRequestByIP(String IP_sent) {
        SentRequest sentRequest = null;
        open();

        Cursor cursor = db.query("SentRequest", null, "IPSent = ?", new String[]{IP_sent}, null, null, null);
        if (cursor != null && cursor.moveToFirst()) {
            sentRequest = new SentRequest();
            sentRequest.setIPSent(cursor.getString(cursor.getColumnIndexOrThrow("IPSent")));
            sentRequest.setName(cursor.getString(cursor.getColumnIndexOrThrow("name")));
            sentRequest.setStatus(cursor.getString(cursor.getColumnIndexOrThrow("status")));
        }

        if (cursor != null) {
            cursor.close();
        }
        close();
        return sentRequest;
    }

    // Xóa dữ liệu từ bảng sent_request theo IP_sent
    public void deleteSentRequestByIP(String IP_sent) {
        open();
        int rowsDeleted = db.delete("SentRequest", "IPSent = ?", new String[]{IP_sent});
        close();
    }

    // Lấy toàn bộ dữ liệu từ bảng sent_request
    public List<SentRequest> getAllSentRequests() {
        List<SentRequest> sentRequests = new ArrayList<>();
        open();
        Cursor cursor = db.query("SentRequest", null, null, null, null, null, null);
        if (cursor != null && cursor.moveToFirst()) {
            do {
                SentRequest sentRequest = new SentRequest();
                sentRequest.setIPSent(cursor.getString(cursor.getColumnIndexOrThrow("IPSent")));
                sentRequest.setName(cursor.getString(cursor.getColumnIndexOrThrow("name")));
                sentRequest.setStatus(cursor.getString(cursor.getColumnIndexOrThrow("status")));

                sentRequests.add(sentRequest);
            } while (cursor.moveToNext());
        }

        if (cursor != null) {
            cursor.close();
        }
        close();
        return sentRequests;
    }
}

ReceiveRequestDAO

plain_texta year ago

package com.example.chatappdemo.DAO;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.util.Log;

import com.example.chatappdemo.DatabaseHelper;
import com.example.chatappdemo.model.ReceiveRequest;

import java.util.ArrayList;
import java.util.List;

public class ReceiveRequestDAO {
    private SQLiteDatabase db;
    private SQLiteOpenHelper dbHelper;

    // Constructor
    public ReceiveRequestDAO(Context context) {
        dbHelper = new DatabaseHelper(context);
    }

    // Mở kết nối
    private void open() throws SQLException {
        db = dbHelper.getWritableDatabase();
    }

    // Đóng kết nối
    private void close() {
        if (db != null && db.isOpen()) {
            db.close();
        }
    }

    // Thêm dữ liệu vào bảng receive_request
    public long insertReceiveRequest(ReceiveRequest receiveRequest) {
        open();
        ContentValues values = new ContentValues();
        values.put("IPRequest", receiveRequest.getIPRequest());
        values.put("name", receiveRequest.getName());
        values.put("publicKey", receiveRequest.getPublicKey());
        long result = 0;
        try {
            result = db.insert("ReceiveRequest", null, values);
        } catch (SQLException e) {
            e.printStackTrace();
            Log.d("ReceiveRequestDAO", e.getMessage());
        }
        close();
        return result;
    }

    // Cập nhật dữ liệu trong bảng receive_request
    public int updateReceiveRequest(ReceiveRequest receiveRequest) {
        open();
        ContentValues values = new ContentValues();
        values.put("IPRequest", receiveRequest.getIPRequest());
        values.put("name", receiveRequest.getName());
        values.put("publicKey", receiveRequest.getPublicKey());

        int result = db.update("ReceiveRequest", values, "IPRequest = ?", new String[]{receiveRequest.getIPRequest()});
        close();
        return result;
    }

    // Lấy dữ liệu từ bảng receive_request theo IP_request
    public ReceiveRequest getReceiveRequestByIP(String IP_request) {
        ReceiveRequest receiveRequest = null;
        open();

        Cursor cursor = db.query("ReceiveRequest", null, "IPRequest = ?", new String[]{IP_request}, null, null, null);
        if (cursor != null && cursor.moveToFirst()) {
            receiveRequest = new ReceiveRequest();
            receiveRequest.setIPRequest(cursor.getString(cursor.getColumnIndexOrThrow("IPRequest")));
            receiveRequest.setName(cursor.getString(cursor.getColumnIndexOrThrow("name")));
            receiveRequest.setPublicKey(cursor.getString(cursor.getColumnIndexOrThrow("publicKey")));
        }

        if (cursor != null) {
            cursor.close();
        }
        close();
        return receiveRequest;
    }

    // Xóa dữ liệu từ bảng receive_request theo IP_request
    public boolean deleteReceiveRequestByIP(String IP_request) {
        open();
        int rowsDeleted = db.delete("ReceiveRequest", "IPRequest = ?", new String[]{IP_request});
        close();
        return rowsDeleted > 0;
    }

    // Lấy toàn bộ dữ liệu từ bảng receive_request
    public List<ReceiveRequest> getAllReceiveRequests() {
        List<ReceiveRequest> receiveRequests = new ArrayList<>();
        open();

        Cursor cursor = db.query("ReceiveRequest", null, null, null, null, null, null);
        if (cursor != null && cursor.moveToFirst()) {
            do {
                ReceiveRequest receiveRequest = new ReceiveRequest();
                receiveRequest.setIPRequest(cursor.getString(cursor.getColumnIndexOrThrow("IPRequest")));
                receiveRequest.setName(cursor.getString(cursor.getColumnIndexOrThrow("name")));
                receiveRequest.setPublicKey(cursor.getString(cursor.getColumnIndexOrThrow("publicKey")));

                receiveRequests.add(receiveRequest);
            } while (cursor.moveToNext());
        }

        if (cursor != null) {
            cursor.close();
        }
        close();
        return receiveRequests;
    }
//    public boolean deleteRequestByIPRequest(String IPRequest) {
//        open();
//        int rowsDeleted = db.delete("Request", "IPRequest = ?", new String[]{IPRequest});
//        close();
//        return rowsDeleted > 0;
//    }
}

MyinfoDAO

plain_texta year ago

package com.example.chatappdemo.DAO;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.util.Log;

import com.example.chatappdemo.DatabaseHelper;
import com.example.chatappdemo.model.Myinfo;
import com.example.chatappdemo.model.ReceiveRequest;

import java.util.ArrayList;
import java.util.List;

public class MyinfoDAO {
    private SQLiteDatabase db;
    private SQLiteOpenHelper dbHelper;

    // Constructor
    public MyinfoDAO(Context context) {
        dbHelper = new DatabaseHelper(context);
    }

    // Mở kết nối
    private void open() throws SQLException {
        db = dbHelper.getWritableDatabase();
    }

    // Đóng kết nối
    private void close() {
        if (db != null && db.isOpen()) {
            db.close();
        }
    }

    // Thêm dữ liệu vào bảng MyModel
    public long insertMyModel(Myinfo model) {
        open();
        ContentValues values = new ContentValues();
        values.put("myIP", model.getMyIP());
        values.put("name", model.getName());
        values.put("publicKey", model.getPublicKey());
        values.put("privateKey", model.getPrivateKey());
        long result = 0;
        try {
            result = db.insert("Myinfo", null, values);
        } catch (SQLException e) {
            e.printStackTrace();
            Log.d("Socket", e.getMessage());
        }
        close();
        return result;
    }

    // Cập nhật dữ liệu trong bảng MyModel
    public int updateMyModel(Myinfo model) {
        open();
        ContentValues values = new ContentValues();
        values.put("myIP", model.getMyIP());
        values.put("name", model.getName());
        values.put("publicKey", model.getPublicKey());
        values.put("privateKey", model.getPrivateKey());

        int result = db.update("Myinfo", values, "myIP = ?", new String[]{model.getMyIP()});
        close();
        return result;
    }

    // Xóa dữ liệu theo myIP
    public int deleteMyModelByIP(String myIP) {
        open();
        int result = db.delete("Myinfo", "myIP = ?", new String[]{myIP});
        close();
        return result;
    }

    // Lấy dữ liệu theo myIP
    // Lấy dữ liệu từ bảng receive_request theo IP_request
    public Myinfo getInfoByIP(String MyIP) {
        Myinfo myinfo=null;
        open();

        Cursor cursor = db.query("Myinfo", null, "myIP = ?", new String[]{MyIP}, null, null, null);
        if (cursor != null && cursor.moveToFirst()) {
            myinfo = new Myinfo();
            myinfo.setMyIP(cursor.getString(cursor.getColumnIndexOrThrow("myIP")));
            myinfo.setName(cursor.getString(cursor.getColumnIndexOrThrow("name")));
            myinfo.setPublicKey(cursor.getString(cursor.getColumnIndexOrThrow("publicKey")));
            myinfo.setPrivateKey(cursor.getString(cursor.getColumnIndexOrThrow("privateKey")));
        }
        if (cursor != null) {
            cursor.close();
        }
        close();
        return myinfo;
    }


    // Lấy toàn bộ dữ liệu từ bảng MyModel
    public List<Myinfo> getAllMyModels() {
        List<Myinfo> modelList = new ArrayList<>();
        open();
        Cursor cursor = db.query("Myinfo", null, null, null, null, null, null);

        if (cursor != null && cursor.moveToFirst()) {
            do {
                Myinfo model = new Myinfo();
                model.setMyIP(cursor.getString(cursor.getColumnIndexOrThrow("myIP")));
                model.setName(cursor.getString(cursor.getColumnIndexOrThrow("name")));
                model.setPublicKey(cursor.getString(cursor.getColumnIndexOrThrow("publicKey")));
                model.setPrivateKey(cursor.getString(cursor.getColumnIndexOrThrow("privateKey")));

                modelList.add(model);
            } while (cursor.moveToNext());
        }

        if (cursor != null) {
            cursor.close();
        }
        close();
        return modelList;
    }
}

MessDAO

javaa year ago

package com.example.chatappdemo.DAO;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.util.Log;

import com.example.chatappdemo.DatabaseHelper;
import com.example.chatappdemo.model.Mess;

import java.util.ArrayList;
import java.util.List;

public class MessDAO {
    private SQLiteDatabase db;
    private SQLiteOpenHelper dbHelper;

    // Constructor
    public MessDAO(Context context) {
        dbHelper = new DatabaseHelper(context);
    }

    // Mở kết nối
    private void open() throws SQLException {
        db = dbHelper.getWritableDatabase();
    }

    // Đóng kết nối
    private void close() {
        if (db != null && db.isOpen()) {
            db.close();
        }
    }

    // Thêm dữ liệu vào bảng Mess
    public long insertMess(Mess mess) {
        open();
        ContentValues values = new ContentValues();
        values.put("conver_id", mess.getConver_id());
        values.put("sender_ip", mess.getSender_ip());
        values.put("mess_text", mess.getMess_text());
        values.put("time", mess.getTime());
        values.put("algorithm", mess.getAlgorithm());
        long result = 0;
        try {
            result = db.insert("Mess", null, values);
        } catch (SQLException e) {
            e.printStackTrace();
            Log.d("Socket", e.getMessage());
        }
        close();
        return result;
    }

    // Cập nhật dữ liệu trong bảng Mess
    public int updateMess(Mess mess) {
        open();
        ContentValues values = new ContentValues();
        values.put("conver_id", mess.getConver_id());
        values.put("sender_ip", mess.getSender_ip());
        values.put("mess_text", mess.getMess_text());
        values.put("time", mess.getTime());
        values.put("algorithm", mess.getAlgorithm());

        int result = db.update("Mess", values, "mess_id = ?", new String[]{String.valueOf(mess.getMess_id())});
        close();
        return result;
    }

    // Lấy toàn bộ dữ liệu từ bảng Mess
    public List<Mess> getAllMessages() {
        List<Mess> messages = new ArrayList<>();
        open();

        Cursor cursor = db.query("Mess", null, null, null, null, null, null);
        if (cursor != null && cursor.moveToFirst()) {
            do {
                Mess mess = new Mess();
                mess.setMess_id(cursor.getInt(cursor.getColumnIndexOrThrow("mess_id")));
                mess.setConver_id(cursor.getInt(cursor.getColumnIndexOrThrow("conver_id")));
                mess.setSender_ip(cursor.getString(cursor.getColumnIndexOrThrow("sender_ip")));
                mess.setMess_text(cursor.getString(cursor.getColumnIndexOrThrow("mess_text")));
                mess.setTime(cursor.getString(cursor.getColumnIndexOrThrow("time")));
                mess.setAlgorithm(cursor.getString(cursor.getColumnIndexOrThrow("algorithm")));

                messages.add(mess);
            } while (cursor.moveToNext());
        }

        if (cursor != null) {
            cursor.close();
        }
        close();
        return messages;
    }

    // Lấy dữ liệu từ bảng Mess theo conver_id
    public List<Mess> getMessagesByConversationId(int conver_id) {
        List<Mess> messages = new ArrayList<>();
        open();

        Cursor cursor = db.query("Mess", null, "conver_id = ?", new String[]{String.valueOf(conver_id)}, null, null, null);
        if (cursor != null && cursor.moveToFirst()) {
            do {
                Mess mess = new Mess();
                mess.setMess_id(cursor.getInt(cursor.getColumnIndexOrThrow("mess_id")));
                mess.setConver_id(cursor.getInt(cursor.getColumnIndexOrThrow("conver_id")));
                mess.setSender_ip(cursor.getString(cursor.getColumnIndexOrThrow("sender_ip")));
                mess.setMess_text(cursor.getString(cursor.getColumnIndexOrThrow("mess_text")));
                mess.setTime(cursor.getString(cursor.getColumnIndexOrThrow("time")));
                mess.setAlgorithm(cursor.getString(cursor.getColumnIndexOrThrow("algorithm")));

                messages.add(mess);
            } while (cursor.moveToNext());
        }

        if (cursor != null) {
            cursor.close();
        }
        close();
        return messages;
    }

    // Xóa dữ liệu từ bảng Mess theo mess_id
    public boolean deleteMessById(int mess_id) {
        open();
        int rowsDeleted = db.delete("Mess", "mess_id = ?", new String[]{String.valueOf(mess_id)});
        close();
        return rowsDeleted > 0;
    }
}

ConversationDAO

javaa year ago

package com.example.chatappdemo.DAO;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.util.Log;

import com.example.chatappdemo.DatabaseHelper;
import com.example.chatappdemo.model.Conversation;

import java.util.ArrayList;
import java.util.List;

public class ConversationDAO {
    private SQLiteDatabase db;
    private SQLiteOpenHelper dbHelper;

    // Constructor
    public ConversationDAO(Context context) {
        dbHelper = new DatabaseHelper(context);
    }

    // Mở kết nối
    private void open() throws SQLException {
        db = dbHelper.getWritableDatabase();
    }

    // Đóng kết nối
    private void close() {
        if (db != null && db.isOpen()) {
            db.close();
        }
    }

    // Thêm dữ liệu vào bảng Conversation
    public void insertConversation(Conversation conversation) {
        open();
        ContentValues values = new ContentValues();
        values.put("IPreceive", conversation.getIPreceive());
        values.put("name", conversation.getName());
        values.put("last_mess", conversation.getLast_mess());
        values.put("last_mess_time", conversation.getLast_mess_time());
        values.put("keyEncrypt128", conversation.getKeyEncrypt128());
        values.put("keyEncrypt256", conversation.getKeyEncrypt256());
        values.put("algorithm",conversation.getAlgorithm());
        long result = 0;
        try{
            result = db.insert("Conversation", null, values);
        }catch (SQLException e){
            e.printStackTrace();
            Log.d("Socket",e.getMessage());
        }

        close();
    }
    // Lấy dữ liệu từ bảng Conversation theo IPreceive (chỉ trả về 1 kết quả)
    public Conversation getConversationByIPReceive(String IPReceive) {
        open();
        Conversation conversation = null;

        Cursor cursor = db.query("Conversation", null, "IPreceive = ?", new String[]{IPReceive}, null, null, null);
        if (cursor != null && cursor.moveToFirst()) {
            conversation = new Conversation();
            conversation.setConver_id(cursor.getInt(cursor.getColumnIndexOrThrow("conver_id")));
            conversation.setIPreceive(cursor.getString(cursor.getColumnIndexOrThrow("IPreceive")));
            conversation.setName(cursor.getString(cursor.getColumnIndexOrThrow("name")));
            conversation.setLast_mess(cursor.getString(cursor.getColumnIndexOrThrow("last_mess")));
            conversation.setLast_mess_time(cursor.getString(cursor.getColumnIndexOrThrow("last_mess_time")));
            conversation.setKeyEncrypt128(cursor.getString(cursor.getColumnIndexOrThrow("keyEncrypt128")));
            conversation.setKeyEncrypt256(cursor.getString(cursor.getColumnIndexOrThrow("keyEncrypt256")));
            conversation.setAlgorithm(cursor.getString(cursor.getColumnIndexOrThrow("algorithm")));
        }

        if (cursor != null) {
            cursor.close();
        }
        close();
        return conversation;
    }
    // Cập nhật dữ liệu trong bảng Conversation
    public void updateConversation(Conversation conversation) {
        open();
        ContentValues values = new ContentValues();
        values.put("IPreceive", conversation.getIPreceive());
        values.put("name", conversation.getName());
        values.put("last_mess", conversation.getLast_mess());
        values.put("last_mess_time", conversation.getLast_mess_time());
        values.put("keyEncrypt128", conversation.getKeyEncrypt128());
        values.put("keyEncrypt256", conversation.getKeyEncrypt256());
        values.put("algorithm",conversation.getAlgorithm());
        int result = db.update("Conversation", values, "conver_id = ?", new String[]{String.valueOf(conversation.getConver_id())});
        close();
    }

    // Lấy toàn bộ dữ liệu từ bảng Conversation
    public List<Conversation> getAllConversations() {
        List<Conversation> conversations = new ArrayList<>();
        open();

        Cursor cursor = db.query("Conversation", null, null, null, null, null, null);
        if (cursor != null && cursor.moveToFirst()) {
            do {
                Conversation conversation = new Conversation();
                conversation.setConver_id(cursor.getInt(cursor.getColumnIndexOrThrow("conver_id")));
                conversation.setIPreceive(cursor.getString(cursor.getColumnIndexOrThrow("IPreceive")));
                conversation.setName(cursor.getString(cursor.getColumnIndexOrThrow("name")));
                conversation.setLast_mess(cursor.getString(cursor.getColumnIndexOrThrow("last_mess")));
                conversation.setLast_mess_time(cursor.getString(cursor.getColumnIndexOrThrow("last_mess_time")));
                conversation.setKeyEncrypt128(cursor.getString(cursor.getColumnIndexOrThrow("keyEncrypt128")));
                conversation.setKeyEncrypt256(cursor.getString(cursor.getColumnIndexOrThrow("keyEncrypt256")));
                conversation.setAlgorithm(cursor.getString(cursor.getColumnIndexOrThrow("algorithm")));
                conversations.add(conversation);
            } while (cursor.moveToNext());
        }

        if (cursor != null) {
            cursor.close();
        }
        close();
        return conversations;
    }
}

Total 5 snippets
1
5 / page