首页 > 范文大全

Python SQLite3数据库操作类

时间：2023年06月04日

来源：小醋王

编辑：本站小编

收藏本文

下载本文

以下文章小编为您整理的Python SQLite3数据库操作类，本文共6篇，供大家阅读。本文原稿由网友“小醋王”提供。

篇1：Python SQLite3数据库操作类

-04-04Python删除指定目录下过期文件的2个脚本分享

2014-01-01paramiko模块安装和使用(远程登录服务器)

-11-11python线程池的实现实例

2014-01-01python实现人人网登录示例分享

2014-04-04Python设计模式之观察者模式实例

-05-05400多行Python代码实现了一个FTP服务器

-09-09Python 字符串定义

2013-08-08pytyon 带有重复的全排列

2014-04-0435个Python编程小技巧

2014-06-06python网络编程学习笔记(七)：HTML和XHTML解析(HTMLParser、Beau

篇2：Python SQLite3数据库操作类

热点排行

Python入门教程超详细1小时学会

python 中文乱码问题深入分析

比较详细Python正则表达式操作指

Python字符串的encode与decode研

Python open读写文件实现脚本

Python enumerate遍历数组示例应

Python 深入理解yield

Python+Django在windows下的开发

python 字符串split的用法分享

python 文件和路径操作函数小结

篇3：Android数据库操作

SQLiteDatabase数据库操作

SQLiteDatabase 打开管理工具 SQLiteExpertSetup

创建数据库

自动创建数据库功能

SQLiteOpenHelper .getReadableDatabase 或.getWriteableDatabase

创建DBOpenHelper extends SQLiteOpenHelper

{

public DBOpenHelper(Context context)

{

super(context,“itcast.db”,null,1); //数据库名称，版本号默认保存目录 <包>/databases/

}

public void onCreate(SQLiteDatabase db) //是在数据库每一次被创建时调用的

{

//通过类SQLiteDatabase的实例来操作SQL语句

db.execSQL(“CREATE TABLE person(personid integer primary key autoincrement,name varchar(20))”);

}

public void onUpgrade(SQLiteDatabase db,int oldVersion,int newVersion)

{

//文件版本号发生变更时调用,如版本由1变为2

db.execSQL(“ALTER TABLE person ADD phone VARCHAR(12) NULL”);

}

Person表类

public class Person

{

private Integer id;

private String name;

private String phone;

public Integer getId()

{

return id;

}

public void setId(Integer id)

{

this.id=id;

}

public String getName()

{

return name;

}

public void setName(String name)

{

this.name=name;

}

public String getPhone()

{

return phone;

}

public void setPhone(String phone)

{

this.phone=phone;

}

public String toString()

{

return “Person [id=” +id+“ , name=”+ name +“, phone=”+phone+“]”;

}

业务PersonService

private DBOpenHelper dbOpenHelper;

public PersonService(Context context){

this.dbOpenHelper = new DBOpenHelper(context);

}

public class PersonService{

public void save(Person person)

{

SQLiteDatabase db=dbOpenHelper.getWriteableDatabase();

db.execSQL(“insert into person(name,phone) values (?,?)”, new Object[]{person.getName(),+person.getPhone()});

//db.close();

}

public void delete(Person person)

{

SQLiteDatabase db=dbOpenHelper.getWriteableDatabase();

db.execSQL(“delete from person where personid=?”, new Object[]{id});

}

public void update(Person person)

{

SQLiteDatabase db=dbOpenHelper.getWriteableDatabase();

db.execSQL(“update person set name=?,phone=? where personid=?”,new Object[]{person.getName(),person.getPhone(),person.getId()});

}

public void find(Person person)

{

SQLiteDatabase db=dbOpenHelper.getReadableDatabase();

Cursor cursor= db.rawQuery(“select * from person where personid=?”, new String[]{id.toString()}); //cursor用于对查询结果集进行随机访问

if(cursor.moveToFirst())

{

int personid=cursor.getInt(cursor.getColumnIndex(“personid”));

String name=cursor.getString(cursor.getColumnIndex(“name”));

String phone=cursor.getString(cursor.getColumnIndex(“phone”));

return new Person(personid,name,phone);

}

cursor.close();

return null;

}

/**

*分页获取记录

*@param offset 跳过前面多少条记录

*@param maxResult 每页获取多少条记录

*@return

**/

public List

getScrollData(int offset,int maxResult)

{

List

persons = new ArrayList

();

SQLiteDatabase db=dbOpenHelper.getReadableDatabase();

Cursor cursor= db.rawQuery(“select * from person order by personid asc limit ?,?”, new String[]{String.valueOf(offset),String.valueOf(maxResult)});

while(cursor.moveToNext()) //类似ResultSet.next()

{

int personid=cursor.getInt(cursor.getColumnIndex(“personid”));

String name=cursor.getString(cursor.getColumnIndex(“name”));

String phone=cursor.getString(cursor.getColumnIndex(“phone”));

person.add(new Person(personid,name,phone));

}

cursor.close();

return persons;

}

public long getCount()

{

SQLiteDatabase db=dbOpenHelper.getReadableDatabase();

Cursor cursor=db.rawQuery(“select count(*) from person”,null);

cursor.moveToFirst();

long result=cursor.getLong(0);

cursor.close();

return result;

}

测试类：

public class PersonServiceTest extends AndroidTestCase

{

private static final String TAG=“PersonServiceTest”;

public void testCreateDB() throws Exception

{

DBOpenHelper dbOpenHelper=new DBOpenHelper(getContext());

dbOpenHelper.getWriteableDatabase();

}

public void testSave() throws Exception

{

PersonService service = new PersonService(this.getContext());

for(int i=0;i<20;i++)

{

Person person =new Person(“zhangxx”+i,“132234324”+i);

service.save(person);

}

public void testDelete() throws Exception

{

PersonService service= new PersonService(this.getContext());

service.delete(21);

}

public void testUpdate() throws Exception

{

PersonService service= new PersonService(this.getContext());

Person person=service.find(1);

person.setName(“zhangxiaoxiao”);

service.update(person);

}

public void testFind() throws Exception

{

PersonService service= new PersonService(this.getContext());

Person person=service.find(1);

Log.i(TAG,person.toString());

}

public void testScrollData() throws Exception

{

PersonService service= new PersonService(this.getContext());

List

person=service.getScrollData(0,5);

for(Person person :persons)

{

Log.i(TAG,person.toString());

}

public void testCount() throws Exception

篇4：java多线程数据库操作Java

import java .io.*; import java.sql.*; public class ToOracle { public static void main(String[] args) { int n = 10;//每个线程执行的个数 //System.out.println(“start action!!!!!!”); ToOracle ac = new ToOracle(); ThreadRun[] testrun = new Threa

importjava.io.*;

import java.sql.*;

public class ToOracle {

public static void main(String[] args) {

int n = 10;//每个线程执行的个数

//System.out.println(“start action!!!!!!”);

ToOracle ac = new ToOracle();

ThreadRun[] testrun = new ThreadRun[21];

for (int i = 1; i <= 21; i++) {

testrun[i] = ac.new ThreadRun();

testrun[i].TRun(n);

System.out.println(“线程” + i + “已经启动”);

}

//testrun[1] = ac.new ThreadRun();

//testrun[1].TRun(10);

for (int i = 1; i <= 21; i++) {

testrun[i].TExit();

}

class ThreadRun {

String blobname = “D:\\eclipse\\test\\test1.txt”; //blob文件名

String clobname = “D:\\eclipse\\test\\test2.txt”; //clob文件名

String in = “insert into ”;

String in1 = “(order_id,ric_code,siz,price,trade_datetime,status,testblob,testclob) values(9,´asdfjkl´,21,123.34567,sysdate,´nill逆耳´,?,?)”;

String tablename = “orders1”;

String sqlstr = “”; // sql 语句

ThreadUseExtends thread = new ThreadUseExtends(blobname, clobname,

sqlstr);

public void TRun(int n) {

sqlstr = in + tablename + in1;

thread = new ThreadUseExtends(blobname, clobname, sqlstr);

//thread.start();

thread.run(n);

* int n=10; for (int i = 1; i <= 21; i++) { while(0

* in + tablename + in1; thread[i] = new ThreadUseExtends(blobname,

* clobname, sqlstr[i]); thread[i].start(); n--; }

* System.out.println(“线程” + i + “已经启动”); }

//System.out.println(“线程1已经启动”);

}

public void TExit() {

thread.interrupt();

}

class ThreadUseExtends extends Thread {

String filename1;//blob filename

String filename2;//clob filename

String str;

//构造函数要有（blob文件名,clob文件名,sql语句）

public ThreadUseExtends(String name1, String name2, String sqlstr) {

filename1 = name1;

filename2 = name2;

str = sqlstr;

}

ReadFiles r1 = new ReadFiles();

public void run(int n) {

while (n >0) {

try {

String url = “jdbc:oracle:thin:@193.9.200.111:1521:ora9i”;

String login = “system”; // use your login here

String password = “ti”; // use your password here

Class.forName(“oracle.jdbc.driver.OracleDriver”);

Connection con = DriverManager.getConnection(url,

String testLong = r1.ReadFile(filename1);

String testLong1 = r1.ReadFile(filename2);

byte[] ba = testLong.getBytes();

System.out.println(“str=” + str);

//String strSql = str; //“insert into

// orders(order_id,ric_code,siz,price,trade_datetime,status,testblob,testclob)

// values(8,´asdfjkl´,21,123.34567,sysdate,´nill逆耳´,?,?)”;

PreparedStatement stm = con.prepareStatement(str);

stm.setBytes(1, ba);

StringReader test = new StringReader(testLong1);

stm.setCharacterStream(2, test, testLong.length());

stm.execute();

stm.close();

con.close();

} catch (Exception e) {

e.printStackTrace();

}

n--;

}//while

}//run

}//ThreadUseExtends class

// ReadFiles class for read text!!

class ReadFiles {

public ReadFiles() {

}

//ReadFile method,read file

public String ReadFile(String FileName) {

String Name = FileName;

String File = “”;

try {

FileReader ReadF = new FileReader(Name);//读文件

BufferedReader HuanChong = new BufferedReader(ReadF);//文件读缓冲.

try {

File = HuanChong.readLine();

} catch (IOException e1) {

// TODO 自动生成 catch 块

e1.printStackTrace();

}

} catch (FileNotFoundException e) {

// TODO 自动生成 catch 块

e.printStackTrace();

}

//System.out.println(“文件：”+File);

return File;

}

}//ReadFiles class

}//ThreadRun class

}//ToOracle class

原文转自：www.ltesting.net

篇5：android数据库SQLite3操作

Android采用关系型数据库SQLite3，它是一个支持SQL轻量级的嵌入式数据库，在嵌入式操作系统上有很广泛的应用，WM采用的也是SQLite3关于过于、原理方面的东西在这篇文章里不会提到，但是如果你想能够快速的学会操作SQLite3，那这就是你要找的文章！

首先，我们看一下api，所有数据库相关的接口、类都在android.database和android.database.sqlite两个包下，虽然只有两个包，但是如果你英文不好或是太懒的话也要迷茫一段时间，其实，我们真正用的到的没有几个！

1、SQLiteOpenHelper（android.database.sqlite.SQLiteOpenHelper）

这是一个抽象类，关于抽象类我们都知道，如果要使用它，一定是继承它！

这个类的方法很少，有一个构造方法

SQLiteOpenHelper(android.content.Context context, java.lang.String name, android.database.sqlite.SQLiteDatabase. CursorFactory factory, int version);

参数不做过多的解释，CursorFactory一般直接传null就可以

public void onCreate(SQLiteDatabase db)

此方法在创建数据库是被调用，所以，应该把创建表的操作放到这个方法里面，一会儿在后面我们会再详细的说如何创建表

public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion)

从方法名上我们就能知道这个方法是执行更新的，没错，当version改变是系统会调用这个方法，所以在这个方法里应该执行删除现有表，然后手动调用onCreate的操作

SQLiteDatabase getReadableDatabase

获取可读的SQLiteDatabase对象

SQLiteDatabase getWritableDatabase()

获取可写的SQLiteDatabase对象

2、SQLiteDatabase（android.database.sqlite.SQLiteDatabase）

关于操作数据库的工作（增、删、查、改）都在这个类里

execSQL(sql)

执行SQL语句，用这个方法+SQL语句可以非常方便的执行增、删、查、改

除此之外，Android还提供了功过方法实现增、删、查、改

long insert(TABLE_NAME, null, contentValues)添加记录

int delete(TABLE_NAME, where, whereValue)删除记录

int update(TABLE_NAME, contentValues, where, whereValue) 更新记录

Cursor query(TABLE_NAME, null, null, null, null, null, null) 查询记录

除此之外，还有很多方法，如：beginTransaction()开始事务、endTransaction()结束事务...有兴趣的可以自己看api，这里就不多赘述了

3、Cursor（android.database.Cursor）

游标（接口），这个很熟悉了吧，Cursor里的方法非常多，常用的有：

boolean moveToPosition(position)将指针移动到某记录

getColumnIndex(Contacts.People.NAME)按列名获取id

int getCount()获取记录总数

boolean requery()重新查询

boolean isAfterLast()指针是否在末尾

boolean isBeforeFirst()时候是开始位置

boolean isFirst()是否是第一条记录

boolean isLast()是否是最后一条记录

boolean moveToFirst()、boolean moveToLast()、boolean moveToNext()同moveToPosition(position)

4、SimpleCursorAdapter（android.widget.SimpleCursorAdapter）

也许你会奇怪了，之前我还说过关于数据库的操作都在database和database.sqlite包下，为什么把一个Adapter放到这里，如果你用过Android的SQLite3，你一定会知道

，这是因为我们对数据库的操作会经常跟列表联系起来

经常有朋友会在这出错，但其实也很简单

SimpleCursorAdapter adapter = new SimpleCursorAdapter(

this,

R.layout.list,

myCursor,

new String[] {DB.TEXT1,DB. TEXT2},

new int[]{ R.id.listTextView1,R.id.listTextView2 });

myListView.setAdapter(adapter);

一共5个参数，具体如下：

参数1:Content

参数2:布局

参数3:Cursor游标对象

参数4:显示的字段，传入String[]

参数5:显示字段使用的组件，传入int[]，该数组中是TextView组件的id

到这里，关于数据库的操作就结束了，但是到目前为止我只做了翻译的工作，有些同学可能还是没有掌握，放心，下面我们一起顺着正常开发的思路理清一下头绪！

前面的只是帮没做过的朋友做下普及，下面才是你真正需要的！

一、写一个类继承SQLiteOpenHelpe

public class DatabaseHelper extends SQLiteOpenHelper

构造方法：

DatabaseHelper(Context context) {

super(context, DATABASE_NAME, null, DATABASE_VERSION);

}

在onCreate方法里写建表的操作

public void onCreate(SQLiteDatabase db) {

String sql = “CREATE TABLE tb_test (_id INTEGER DEFAULT '1' NOT NULL PRIMARY KEY AUTOINCREMENT,class_jb TEXT NOT NULL,class_ysbj TEXT NOT NULL,title TEXT NOT NULL,content_ysbj TEXT NOT NULL)”;

db.execSQL(sql);//需要异常捕获

}

在onUpgrade方法里删除现有表，然后手动调用onCtreate创建表

public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {

String sql = “drop table ”+tbname;

db.execSQL(sql);

onCreate(db);

}

定义对表增、删、查、改的方法，这里用的是SQLiteOpenHelper提供的方法，也可以用sql语句实现，都是一样的

关于获取可读/可写SQLiteDatabase，我不说大家也应该会想到，只有查找才会用到可读的SQLiteDatabase

/**

*添加数据

public long insert(String tname, int tage, String ttel){

SQLiteDatabase db= getWritableDatabase();//获取可写SQLiteDatabase对象

//ContentValues类似map，存入的是键值对

ContentValues contentValues = new ContentValues();

contentValues.put(“tname”, tname);

contentValues.put(“tage”, tage);

contentValues.put(“ttel”, ttel);

return db.insert(tbname, null, contentValues);

}

/**

*删除记录

* @param _id

public void delete(String _id){

SQLiteDatabase db= getWritableDatabase();

db.delete(tbname,

“_id=?”,

new String[]{_id});

}

/**

*更新记录的，跟插入的很像

public void update(String _id,String tname, int tage, String ttel){

SQLiteDatabase db= getWritableDatabase();

ContentValues contentValues = new ContentValues();

contentValues.put(“tname”, tname);

contentValues.put(“tage”, tage);

contentValues.put(“ttel”, ttel);

db.update(tbname, contentValues, “_id=?”, new String[]{_id});

}

/**

*查询所有数据

* @return Cursor

public Cursor select(){

SQLiteDatabase db = getReadableDatabase();

return db.query(

tbname,

new String[]{“_id”,“tname”,“tage”,“ttel”,“taddr”},

null,

null, null, null, “_id desc”);

}

关于db.query方法的参数，有很多，为了防止大家弄乱，我简单说一下

参数1：表名

参数2：返回数据包含的列信息，String数组里放的都是列名

参数3：相当于sql里的where，sql里where后写的内容放到这就行了，例如：tage>?

参数4：如果你在参数3里写了?（知道我为什么写tage>?了吧），那个这里就是代替?的值接上例：new String[]{“30”}

参数5：分组，不解释了，不想分组就传null

参数6：having，想不起来的看看SQL

参数7：orderBy排序

到这里，你已经完成了代码最多的第一步！我们来看看都用到了那些类：

SQLiteOpenHelper我们继承使用的

SQLiteDatabase增删查改都离不开它，即使你直接用sql语句，也要用到execSQL(sql)

二、这里无非是对DatabaseHelper类定义方法的调用，没什么可说的，不过我还是对查询再唠叨几句吧

Android查询出来的结果一Cursor形式返回

cursor = sqLiteHelper.select();//是不是很简单？

查询出来的cursor一般会显示在listView中，这就要用到刚才提到的SimpleCursorAdapter

SimpleCursorAdapter adapter = new SimpleCursorAdapter(

this,

R.layout.list_row,

cursor,

new String[]{“tname”,“ttel”},

new int[]{R.id.TextView01,R.id.TextView02}

);

是不是很简单呢，任何复杂的工程都是通过简单的代码实现的.

篇6：sql数据库备份和恢复常用操作

1.新建一个同名的数据库

2.再停掉sql server(注意不要分离数据库)

3.用原数据库的数据文件覆盖掉这个新建的数据库

4.再重启sql server

5.此时打开企业管理器时会出现置疑，先不管，执行下面的语句（注意修改其中的数据库名)

6.完成后一般就可以访问数据库中的数据了,这时,数据库本身一般还要问题,解决办法是,利用

数据库的脚本创建一个新的数据库,并将数据导进去就行了.

USE MASTER

SP_CONFIGURE 'ALLOW UPDATES',1 RECONFIGURE WITH OVERRIDE

UPDATE SYSDATABASES SET STATUS =32768 WHERE NAME='置疑的数据库名'

sp_dboption '置疑的数据库名', 'single user', 'true'

DBCC CHECKDB('置疑的数据库名')

update sysdatabases set status =28 where name='置疑的数据库名'

sp_configure 'allow updates', 0 reconfigure with override

sp_dboption '置疑的数据库名', 'single user', 'false'

Python SQLite3数据库操作类.doc

将本文的Word文档下载到电脑，方便收藏和打印

推荐度：

点击下载文档

Python SQLite3数据库操作类

篇1：Python SQLite3数据库操作类

篇2：Python SQLite3数据库操作类

最近更 新

热 点 排 行

篇3：Android数据库操作

篇4：java多线程数据库操作Java

篇5：android数据库SQLite3操作

篇6：sql数据库备份和恢复常用操作

最近更新

热点排行