mysql 连接
package com.cn.dao;
import java.sql.DriverManager;
public class BaseDao {
private java.sql.Connection conn;
private java.sql.Statement stat;
private java.sql.ResultSet rs;
public BaseDao(){
}
public void openConnection() {
try{
Class.forName("com.mysql.jdbc.Driver");
conn=DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "wp");
}catch(Exception e){
e.printStackTrace();
}
}
public int exectue(String sql){
int a=0;
try{
stat=conn.createStatement();
a=stat.executeUpdate(sql);
}catch (Exception e) {
e.printStackTrace();
}
return a;
}
public java.sql.ResultSet getRs(String sql){
try{
stat=conn.createStatement();
rs=stat.executeQuery(sql);
}catch (Exception e) {
e.printStackTrace();
}
return rs;
}
public void close(){
try{
if(rs!=null){
rs.close();
}
stat.close();
conn.close();
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
}
package com.cn.dao;
import java.sql.SQLException;
import java.util.ArrayList;
import com.cn.bean.UserBean;
import com.cn.sys.PageUtil;
public class Userdao {
public boolean addUser(String username,String pwd,String tel){
String sql="insert into users value('"+username+"','"+pwd+"','"+tel+"')";
BaseDao dao=new BaseDao();
dao.openConnection();
int a=dao.exectue(sql);
dao.close();
if(a!=0){
return true;
}else{
return false;
}
}
public boolean updateUser(String username,String pwd,String tel){
String sql="update users set pwd='"+pwd+"',tel='"+tel+"' where username='"+username+"'";
BaseDao dao=new BaseDao();
dao.openConnection();
int a=dao.exectue(sql);
dao.close();
if(a!=0){
return true;
}
else{
return false;
}
}
public ArrayList<UserBean> getArry(PageUtil page){
String sql="select * from users";
BaseDao dao=new BaseDao();
int index=page.getPageIndex();
int c=page.getItemCountPerPage();
int count=(index-1)*c+1;
dao.openConnection();
java.sql.ResultSet rs=dao.getRs(sql);
ArrayList<UserBean> arry=new ArrayList<UserBean>();
try{
rs.absolute(count);
for(int i=0;i<c;i++){
UserBean u=new UserBean();
u.setUsername(rs.getString("username"));
u.setPwd(rs.getString("pwd"));
u.setTel(rs.getString("tel"));
arry.add(u);
if(!rs.next()){
break;
}
}
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}finally{
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
dao.close();
}
return arry;
}
public UserBean getBean(String username){
String sql="select * from users where username='"+username+"'";
BaseDao dao=new BaseDao();
dao.openConnection();
java.sql.ResultSet rs=dao.getRs(sql);
UserBean u=new UserBean();
try{
while(rs.next()){
u.setUsername(rs.getString("username"));
u.setPwd(rs.getString("pwd"));
u.setTel(rs.getString("tel"));
}
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}finally{
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
dao.close();
}
return u;
}
public int getCount(){
String sql="select count(*) as c from users";
BaseDao dao=new BaseDao();
dao.openConnection();
int a=0;
java.sql.ResultSet rs=dao.getRs(sql);
try{
while(rs.next()){
a=rs.getInt("c");
}
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}finally{
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
dao.close();
}
return a;
}
}
分享到:
相关推荐
Mysql 连接资源Jar,Mysql连接jar包.
MySQL连接工具 绿色版的 很简单的操作MySQL数据库
nodejs封装好的mysql数据库模块,使用mysql连接池以及附带百万mysql测试数据,实现mysql数据库的增删改查功能,使用方法很详细。
mysql连接驱动jar包
主要给大家介绍了关于MySQL连接抛出Authentication Failed错误的分析与解决方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
非常好用的mysql连接工具支持多种安全连接方式,附带key
易语言MYSQL连接池模块源码,MYSQL连接池模块,GetThis,初始化,关闭类线程,线程_测试,其他_附加文本,连接池初始化,取mysql句柄,释放mysql句柄,取空闲句柄数,销毁连接池,取_类_函数地址,取指针内容_整数,取变量地址_...
MySql连接字符串问题,我搞了半天。对于初学者来说还是有用的。
最新MySQL连接jar包(mysql-connector-java-8.0.16.jar)
mysql连接工具nav150
包含两个版本的驱动包:mysql-connector-java-5.0.3-bin.jar和mysql-connector-java-5.1.39-bin.jar
mac下的mysql连接工具,navicat,支持最新的mojave版本。亲测可用。希望大家能用的给个好评。
网络收集 C++ MYSQL 连接池 可编译运行 需要boost 和 mysql c++ connector
CH07MySQL连接器JDBC和连接池.ppt
线程池和mysql连接池的实现,可以在ubuntu12.04下完美实现,mysql连接池需要用到mysql-connector c++
关于MySql连接jsp的驱动问题,包括连接的详细步骤,里面附有截图,还有各个注意事项,还附加了一个测试代码,希望对大家有所帮助
java_mysql连接的jar包
用于myeclipse 连接Mysql的数据库架包
mysql连接工具mysql连接工具mysql连接工具mysql连接工具mysql连接工具mysql连接工具
MySql连接数据库(方法、代码、用到的所有组件)