插入U盘，自动复制数据库信息和相关文件

com.example.acer.readdata; import android.content.BroadcastReceiver; import android.content.Context; import android.content.Intent; import android.content.IntentFilter; import android.os.Message; import android.util.Log; /** * Created by acer on 2015/11/11. */ public class ReadData extends BroadcastReceiver { MainActivity execactivity; private static final String TAG = "UsbStateReceiver"; public static final int USB_STATE_MSG = 0x00020; public static final int USB_STATE_ON = 0x00021; public static final int USB_STATE_OFF = 0x00022; public IntentFilter filter = new IntentFilter(); public ReadData(Context context) { execactivity = (MainActivity) context; filter.addAction(Intent.ACTION_MEDIA_MOUNTED); //表示SD卡已挂载 filter.addAction(Intent.ACTION_MEDIA_CHECKING);//表示正在检测SD卡 filter.addAction(Intent.ACTION_MEDIA_EJECT);//表示用户欲卸载SD卡，但是SD卡上的部分内容尚处于打开状态 filter.addAction(Intent.ACTION_MEDIA_REMOVED);//表示SD卡已经被移除 filter.addDataScheme("file");//必须要有此行，否则无法接收到广播 Log.v("msg","filter"); } //登记接收器 public Intent registerReceiver(){ return execactivity.registerReceiver(this,filter); } //关闭接收器 public void unregisterReceiver(){ execactivity.unregisterReceiver(this); } @Override public void onReceive(Context context, Intent intent) { if(execactivity.mHandler == null){ Log.v("msg","null"); return; } Message msg = new Message(); msg.what = USB_STATE_MSG; if( intent.getAction().equals(Intent.ACTION_MEDIA_MOUNTED )/* || intent.getAction().equals(Intent.ACTION_MEDIA_CHECKING)*/){ msg.what = USB_STATE_ON; Log.v("msg","msg.arg1 = USB_STATE_ON"); execactivity.mHandler.sendMessage(msg); }else{ msg.what = USB_STATE_OFF; Log.v("msg","msg.arg1 = USB_STATE_OFF"); execactivity.mHandler.sendMessage(msg); } Log.v("msg", "sendMessage"); } } **MyDatabastHelper.java** package com.example.acer.readdata; import android.content.Context; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteOpenHelper; import android.util.Log; /** * Created by acer on 2015/11/16. */ public class MyDatabaseHelper extends SQLiteOpenHelper { /* *catalog_table 分类表 * type 所属应用 0属于绘本 1属于视频 2属于游戏 * name 名称 * icon 图标 * index 放置的顺序序号 最小的放在最前面 */ public static final String catalog_table = "create table catalog(" + "id integer primary key autoincrement," + "type integer" + "name text" + "icon text" + "index integer)"; /* *book_table 内容表 * parentid 0属于绘本 1属于视频 2属于游戏 * catalogid 分类id * type Book类别 按照类别，来打开这本书，可能是视频，可能是绘本的zip，也可能是apk * name 名称 * icon 图标 * url 书的路径 （书或者是个apk） * index 显示的序号 * readcount 阅读的次数 * pos 上次阅读的位置 （百分比表示 20表示为阅读到20%） * readtume 最近一次阅读时间 * reverse1 0是竖版，1是横版 *reverse2 扩展为书的别名（例如 猴子捞月亮，别名：hzlyl） */ public static final String book_table = "create table book(" + "id integer primary key autoincrement," + "parentid integer" + "catalogid integer" + "type integer" + "name text" + "icon text" + "url text" + "index integer" + "readcount integer" + "pos integer" + "readtime integer" + "reverse1 integer" + "reverse2 integer)"; public MyDatabaseHelper(Context context,String name,SQLiteDatabase.CursorFactory factory,int version){ super(context,name,factory,version); Log.v("SQL", " MyDatabaseHelper"); } @Override public void onCreate(SQLiteDatabase db) { db.execSQL(catalog_table); db.execSQL(book_table); Log.v("SQL", "onCreate"); } @Override public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { db.execSQL("drop table if exists book_table"); db.execSQL("drop table if exists catalog_table"); Log.v("SQL","onUpgrade"); onCreate(db); } } **MainActivity.java** package com.example.acer.readdata; import android.app.Activity; import android.app.AlertDialog; import android.app.ProgressDialog; import android.content.ContentValues; import android.content.DialogInterface; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; import android.os.Environment; import android.os.Message; import android.support.v7.app.ActionBarActivity; import android.os.Bundle; import android.util.Log; import android.view.Menu; import android.view.MenuItem; import android.os.Handler; import android.view.View; import android.widget.Button; import android.widget.ProgressBar; import android.widget.TextView; import android.widget.Toast; import java.io.BufferedReader; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.FileReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.UnsupportedEncodingException; import java.net.URLEncoder; import java.util.Scanner; import java.util.logging.LogRecord; import static android.widget.Toast.*; //采用广播方式监听U盘插拔的信息 public class MainActivity extends Activity { MyHandler mHandler; MyThread thread; ProgressDialog progressDialog; private ReadData usbstates; private MyDatabaseHelper dbHelper; private int i = 2; private int type; private int csvline = 2; //csv内有多少行记录 private int nShowProgress = 0x1000; //显示进度条 private int nHideProgress = 0x1001; //隐藏进度条 private int nStepProgress = 0x1002; //更新进度条 private int nMutiProgress = 0x1003; //更新进度条 private int toast = 0x1004; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.layout); // 让数据库更新执行（未用） dbHelper = new MyDatabaseHelper(this, "book.db", null, 5); Log.v("msg2", "dbHelper"); mHandler = new MyHandler(); thread = new MyThread(); usbstates = new ReadData(this); //进度条 progressDialog = new ProgressDialog(MainActivity.this); progressDialog.setIcon(R.mipmap.ic_launcher); progressDialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL); } protected void onStart() { super.onStart(); usbstates.registerReceiver(); } protected void onStop() { super.onStop(); usbstates.unregisterReceiver(); } class MyHandler extends Handler { public MyHandler() { } public void handleMessage(Message msg) { super.handleMessage(msg); Log.v("msg", "ainactivity handler"); if (msg.what == 0x0021) { Log.v("msg", "Main.SB_STATE_ON"); thread.start(); Log.v("msg", "Main.thread.start"); } else if (msg.what == 0x0022) { Log.v("msg", "Main SB_STATE_OFF"); } else if (msg.what == 8888) { useChoice(); Log.v("msg", "useChoice"); } else if(msg.what == nShowProgress) { progressDialog.setTitle("更新数据中"); int nMaxProgress = msg.arg2; Log.v("bar", "msg.what =" + nShowProgress + "msg.arg2 =" + nMaxProgress ); progressDialog.setMax(nMaxProgress); progressDialog.show(); } else if(msg.what == nHideProgress) { Log.v("bar", "msg.what =" + nShowProgress); progressDialog.hide(); } else if(msg.what == nStepProgress) { int iStep = msg.arg2; Log.v("bar", "msg.what =" + nShowProgress + "" + iStep); progressDialog.setProgress(iStep); } else if(msg.what == nMutiProgress) { int nMax = msg.arg1; int iStep = msg.arg2; progressDialog.setMax(nMax); Log.v("bar", "msg.what =" + nShowProgress + "" + iStep); progressDialog.setProgress(iStep); } else if(msg.what == toast) { Toast.makeText(MainActivity.this, "更新成功", Toast.LENGTH_SHORT).show(); Log.v("copy ","弹出更新成功"); } } } //判断ini，发消息给主线程，让主线程弹出一个对话框，让用户选择是否更新数据 class MyThread extends Thread { public MyThread() {} @Override public void run() { // TODO Auto-generated method stub super.run(); Log.v("msg1", "Main.MyThread"); //扫描U盘\HappyChildren_update下的update.ini文件，若文件内update=yes则提示用户是否更新数据 // 读取U盘指定目录下的文件 File file = new File("/storage/external_storage/sda1/HappyChildren_update/update.ini"); if (file == null) { Log.v("msg1", "file is null"); } else Log.v("msg1", "file is not null"); try { Log.v("msg1", "try"); //判断文件内update是否等于YES FileReader in = new FileReader(file); Log.v("msg1", "in" + in); char byt[] = new char[1024]; String substr = "update=YES"; int len = in.read(byt); //将字节读取数组 Log.v("msg1", "in.read:" + len); String text = new String(byt, 0, len); //获取信息 Log.v("msg1", "text:" + text); //如果为YES if (text.equals(substr)) { // if(true){ Log.v("msg", "eqyals"); //让用户选择是否更新数据 //发消息给主线程，让主线程弹出一个对话框 Message msg = new Message(); msg.what = 8888; mHandler.sendMessage(msg); Log.v("msg", "用户选择更新数据"); } else { Log.v("msg", "else"); } in.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } } //弹出对话框让用户选择 public void useChoice() { AlertDialog.Builder builder = new AlertDialog.Builder(MainActivity.this); builder.setTitle("更新数据");//窗口名 builder.setIcon(R.mipmap.ic_launcher); //添加一个小图片 builder.setMessage("是否更新数据？"); Log.v("msg2", "useChoice is use"); //用户选择确定 builder.setPositiveButton("更新", new DialogInterface.OnClickListener() { public void onClick(DialogInterface dialog, int which) { //隐藏后选择窗口 dialog.dismiss(); Log.v("msg2", "useChoice is onClick yes"); //操作数据库和文件 dowithFile(); } }); //若用户选择取消，则结束 builder.setNegativeButton("取消", new DialogInterface.OnClickListener() { public void onClick(DialogInterface dialog, int which) { dialog.cancel(); } }); builder.show(); } //操作数据库和文件 private void dowithFile() { Thread th = new Thread(new Runnable() { @Override public void run() { // TODO Auto-generated method stub File file = new File("/storage/external_storage/sda1/HappyChildren_update/update.csv"); //判断csv是否存在 if (file.exists()) { Log.v("msg2", "useChoice is exosts"); // 存在则进行while循环 try { Log.v("msg2", "useChoice is try"); BufferedReader reader = new BufferedReader(new FileReader("/storage/external_storage/sda1/HappyChildren_update/update.csv")); reader.readLine(); String line = null; Log.v("msg2", "useChoice is tryover"); //获取csv总行数 reader.mark((int) file.length() + 1); //在行首做个标记 while ((line = reader.readLine()) != null) { csvline++; Log.v("csv", "csvline: " + csvline); } //发消息给主线程，让主线程弹出一个对话框,显示操作数据库的进度条 Message msg = mHandler.obtainMessage(); msg.what = nShowProgress; msg.arg2 = csvline; mHandler.sendMessage(msg); Log.v("copy", "显示进度条"); reader.reset(); //从mark那一行开始读 while ((line = reader.readLine()) != null) { //打开数据库 SQLiteDatabase db = SQLiteDatabase.openOrCreateDatabase("/storage/emulated/0/HappyChildren1/db/book.db", null); //对csv中栏目进行判断 String sType = csv(i, 3); Log.v("csv", "sType: " + sType); if (sType.equals("绘本教学") == true) { type = 0; Log.v("type", "sType type = 0"); } else if (sType.equals("视频教学") == true) { type = 1; Log.v("type", "sType type = 1"); } else if (sType.equals("游戏娱乐") == true) { type = 2; Log.v("type", "sType type = 2"); } //根据type和书分类去判断是否和catalog_table表中的type和name相同，若相同，返回id;若不存在则创建记录，并返回id Cursor catalogtable = db.rawQuery("select * from catalog_table where type = ? and name like ?", new String[]{String.valueOf(type), csv(i, 4)}); int count = catalogtable.getCount(); Log.v("type", "catalogtable : " + count); if (count == 0) { //catalog_table不存在该条记录,插入读取到的数据 ContentValues values2 = new ContentValues(); Log.v("type", "values2: " + values2); values2.put("type", type); values2.put("name", csv(i, 4)); long catalogId = db.insert("catalog_table", null, values2); //根据catalog_table表中返回的id和csv读取到的书的名称去判断book_table表中是否存在该记录，若存在，则update；若不存在，则insert记录 typeSort(catalogId, type); } else { //已经存在该记录，提取该记录的id Cursor cursor = db.rawQuery("select * from catalog_table where type = ? and name = ?", new String[]{String.valueOf(type), csv(i, 4)}); cursor.moveToFirst(); int catalogId = cursor.getInt(cursor.getColumnIndex("_id")); Log.v("type", "catalogId : " + catalogId); //根据catalog_table表中返回的id和csv读取到的书的名称去判断book_table表中是否存在该记录，若存在，则update；若不存在，则insert记录 typeSort(catalogId, type); } ++i; //进度表 Message msg1 = mHandler.obtainMessage(); msg1.what = nStepProgress; msg1.arg2 = i; mHandler.sendMessage(msg1); // Thread.sleep(500); } //while循环结束 //copy文件夹 String oldPath = "/storage/external_storage/sda1/HappyChildren_update/books"; String newPath = "/storage/emulated/0/HappyChildren1/books"; Log.v("copy", "oldpath: " + oldPath + " newpath:" + newPath); copyFolder(oldPath, newPath); Log.v("copy", "copyFolder"); //隐藏进度表 Message msg3 = mHandler.obtainMessage(); msg3.what = nHideProgress; mHandler.sendMessage(msg3); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } else { //如果文件不存在，则提示用户缺少csv文件，无法更新 Toast.makeText(MainActivity.this, "U盘缺少csv文件，无法更新", LENGTH_SHORT).show(); } //将ini文件内的YES改为NO iniFile(); //提示用户更新成功 Message msg1 = mHandler.obtainMessage(); msg1.what = toast; mHandler.sendMessage(msg1); Log.v("copy","提示用户更新完成"); } }); th.start(); } //操作book_table表内的记录，增加或修改 public void typeSort(long catalogId, int parentid) { SQLiteDatabase db = SQLiteDatabase.openOrCreateDatabase("/storage/emulated/0/HappyChildren1/db/book.db", null); //根据catalog_table表中返回的id和csv读取到的书的名称去判断book_table表中是否存在该记录 Cursor booktable = db.rawQuery("select * from book_table where catalogid = ? and name like ?", new String[]{String.valueOf(catalogId), csv(i, 1)}); int count = booktable.getCount(); Log.v("type", "booktable : " + count); if (count == 0) { //创建记录 ContentValues values = new ContentValues(); values.put("name", csv(i, 1)); values.put("icon", csv(i, 6)); values.put("reverse1", csv(i, 8)); values.put("parentid", String.valueOf(parentid)); values.put("type", 0); values.put("catalogid",String.valueOf(catalogId)); values.put("url", csv(i, 7)); db.insert("book_table", null, values); } else { //更新记录 update ContentValues values3 = new ContentValues(); values3.put("url",csv(i,7)); db.update("book_table", values3, "name = ?", new String[]{csv(i, 1)}); } } //读取csv内数据 public String csv(int row, int col) { String sRet = ""; Log.v("msg2", "Csv"); try { Log.v("msg2", "CsvTry"); InputStream in = new FileInputStream(new File("/storage/external_storage/sda1/HappyChildren_update/update.csv")); InputStreamReader input = new InputStreamReader(in, "gb2312"); // BufferedReader reader = new BufferedReader(new FileReader("/storage/external_storage/sda1/HappyChildren_update/update.csv")); BufferedReader reader = new BufferedReader(input); Log.v("msg2", "CsvReader"); // reader.readLine();//第一行信息，为标题信息，不用,如果需要，注释掉 String line = null; int index = 0; while ((line = reader.readLine()) != null) { Log.v("msg2", "CsvWhile"); if (index == row - 1) { String item[] = line.split(",");//CSV格式文件为逗号分隔符文件，这里根据逗号切分 Log.v("msg2", "CsvIf"); if (item.length >= col - 1) { Log.v("msg2", "CsvIFif"); String last = item[col - 1];//所要数据 sRet = last; Log.v("msg2", "last: " + last); } break; } //int value = Integer.parseInt(last);//如果是数值，可以转化为数值 index++; Log.v("msg2", "index: " + index); } } catch (Exception e) { e.printStackTrace(); Log.v("msg2", "exception"); } Log.v("csv", "sRet = " + sRet); return sRet; } //copy整个文件夹内容，oldPath 原文件路径 ，newPath 复制到的路径 public void copyFolder(String oldPath, String newPath) { try { (new File(newPath)).mkdirs(); //如果文件夹不存在 则建立新文件夹 // 获取源文件夹当前下的文件或目录 File f = new File(oldPath); Log.v("copy", "f: " + f); String[] file = f.list(); int nFile = (int) file.length; //发送消息，弹出进度条 Message msg = mHandler.obtainMessage(); msg.what = nMutiProgress; msg.arg1 = nFile; msg.arg2 = 0; mHandler.sendMessage(msg); Log.v("copy", "显示进度条"); File temp = null; for (int i = 0; i < file.length; i++) { if (oldPath.endsWith(File.separator)) { temp = new File(oldPath + file[i]); Log.v("copy", "temp: " + temp); } else { temp = new File(oldPath + File.separator + file[i]); Log.v("copy", "temp: " + temp); } if (temp.isFile()) { FileInputStream input = new FileInputStream(temp); FileOutputStream output = new FileOutputStream(newPath + "/" + (temp.getName()).toString()); byte[] b = new byte[1024 * 1024]; int len; File newfile = new File(newPath); while ((len = input.read(b)) != -1) { Log.v("copy", "len:" + len); output.write(b, 0, len); Log.v("copy", "len: " + len); //进度表 Message msg1 = mHandler.obtainMessage(); msg1.what = nMutiProgress; msg1.arg1 = nFile; msg1.arg2 = i+1; mHandler.sendMessage(msg1); Log.v("copy", "sendMessage(msg1)"); } Log.v("copy", "while over"); output.flush(); output.close(); input.close(); } if (temp.isDirectory()) {//如果是子文件夹 copyFolder(oldPath + "/" + file[i], newPath + "/" + file[i]); Log.v("copy", "子文件夹"); } } } catch (Exception e) { System.out.println("复制整个文件夹内容操作出错"); e.printStackTrace(); } } //将ini文件内的update=YES修改为update=NO； public void iniFile() { File file = new File("/storage/external_storage/sda1/HappyChildren_update/update.ini"); Log.v("msg2", "iniFile"); try { FileInputStream in = new FileInputStream(file); byte byt[] = new byte[1024]; int len = in.read(byt); //从文件中读取信息 Log.v("msg2", "len:" + len); //创建FileOUtputStream对象 FileOutputStream out = new FileOutputStream(file); //创建byte数组 byte by[] = "update=NO".getBytes(); out.write(by); //将数组信息写入到文件中 out.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }

插入U盘，自动复制数据库信息和相关文件

标签：