一、連線資料庫
1.獲取連線
public static connection mysqlconnect() throws exception//關閉連線
public static void close(connection conn, preparedstatement ps) catch (sqlexception e)
}if (ps != null) catch (sqlexception e) }}
//關閉連線
public static void close(connection conn, preparedstatement ps,resultset rs) catch (sqlexception e)
}if (ps != null) catch (sqlexception e)
}if(rs!=null) catch (sqlexception e)
}}
1.更新一條資料
/**
* * @param conn 資料庫連線
* @param sql 傳入sql語句
* @param args 傳入值
* @throws exception
*/public void update(connection conn, string sql, object... args) throws exception
//提交
ps.execute();
//關閉連線
sqlconnect.close(null, ps);
}
/**
* * @param conn 資料庫連線
* @param sql sql語句
* @param lists 傳入的值
* @throws exception
*/public void updates(connection conn, string sql, listlists) throws exception
ps.addbatch();
//沒新增500條進行新增至資料庫並沒有提交
if (i % 500 == 0)
}ps.executebatch();
//提交
conn.commit();
//long end = system.currenttimemillis();
// system.out.println("花費時間為：" + (end - start));
sqlconnect.close(null, ps);
}
將查詢結果放置在map中
/**
* * @param conn 資料庫連線
* @param sql sql語句
* @param args 傳入的值
* @return 返回map值
* @throws exception
*/public mapselect(connection conn, string sql, object... args) throws exception
//獲取返回值
resultset rs = ps.executequery();
//獲取元資料集
resultsetmetadata rsmd = rs.getmetadata();
//返回資料的列數
int count = rsmd.getcolumncount();
//儲存每一列的列名
string names = new string[count];
//儲存返回的資料
mapmaps = new hashmap<>(8);
if (rs.next())
//獲取返會的資料
for (int i = 0; i < count; i++)
}//關閉這個方法中的所有流
sqlconnect.close(null, ps, rs);
return maps;
}
/**
* * @param conn 獲取資料庫連線
* @param sql sql語句
* @param args 傳入條件值
* @return
* @throws exception
*/public list> selects(connection conn, string sql, object... args) throws exception
//獲取結果集
resultset rs = ps.executequery();
//返回元資料
resultsetmetadata rsmd = rs.getmetadata();
int count = rsmd.getcolumncount();
string names=new string[count];
list> lists = new arraylist<>();
boolean k=true;
while (rs.next()) catch (ioexception e)
//資料庫連線池
try catch (exception e)
}//獲取資料集
public static connection getconnect() throws sqlexception
public static void closeconnect(connection conn, preparedstatement ps, resultset rs)
public static void closeconnect(connection conn, preparedstatement ps)
}
1.修改資料
/**
* * @param sql sql語句
* @param obj 傳入值
* @throws exception
*/public void update(string sql,object...obj) throws exception
/**
** @param sql 傳入sql
* @param args 傳入值
* @throws exception
*/public t select(classclazz, string sql,object...args) throws exception
/**
* * @param clazz 類的class檔案
* @param sql sql語句
* @param args 傳入值
* @param 泛型
* @return 返回查詢結果
* @throws exception
*/public listselect2(classclazz,string sql,object...args) throws exception
/**
** @param sql sql語句
* @param args 傳入值
* @return 返回查詢結果
* @throws exception
*/public list> select4(string sql,object...args) throws exception
/**
* * @param sql sql語句
* @param args 傳入值
* @return 返回值
* @throws exception
*/public long select5(string sql,object...args) throws exception
public void select6(string sql,object...arg) throws exception
};runner.query(conn, sql, rsh,arg);
conn.close();
}
php連線資料庫增刪改查
header content type text html charset utf 8 1.建立和資料庫的連線 第乙個引數 連線資料的主機 第二個引數 連線資料的賬號 第三個引數 密碼 第四個引數 資料庫 預設連線的是3306 conn newmysqli localhost root ishop ...
連線資料庫並進行增刪改查
public class jdbcutil catch classnotfoundexception e 資料庫連線 return public static connection geconnection catch sqlexception e return connection 資料庫增刪改 ...
python連線資料庫實現增刪改查
import pymysql conn pymysql.connect host localhost port 3306,user root password root charset utf8 print 建立cursor物件，查詢資料庫 cur conn.cursor r cur.execute...