[java] view plaincopyprint?
//注意,这是连接mysql的方法 //注意,这是连接mysql的方法
注意连接数据库的时候
(1)打开db browser 新建一个database driver,注意添加driver jars的时候添加的包,我的是mysql-connector-java-5.0.3-bin.jar
(2)要将数据库jar包拷贝到工程下的web-inf\lib下
[java] view plaincopyprint?
import java.sql.connection;//java包 public class dbconnection { private string dbdriver=com.mysql.jdbc.driver; private string dburl=jdbc:mysql://[ip地址]:[端口号]/[数据库名];//根据实际情况变化 private string dbuser=root; private string dbpass=root; public connection getconn() { connection conn=null; try { class.forname(dbdriver); } catch (classnotfoundexception e) { e.printstacktrace(); } try { conn = drivermanager.getconnection(dburl,dbuser,dbpass);//注意是三个参数 } catch (sqlexception e) { e.printstacktrace(); } return conn; } }
import java.sql.connection;//java包public class dbconnection { private string dbdriver=com.mysql.jdbc.driver; private string dburl=jdbc:mysql://[ip地址]:[端口号]/[数据库名];//根据实际情况变化 private string dbuser=root; private string dbpass=root; public connection getconn() { connection conn=null; try { class.forname(dbdriver); } catch (classnotfoundexception e) { e.printstacktrace(); } try { conn = drivermanager.getconnection(dburl,dbuser,dbpass);//注意是三个参数 } catch (sqlexception e) { e.printstacktrace(); } return conn; } }
2. 插入操作
[java] view plaincopyprint?
public int insert() { int i=0; string sql=insert into (表名)(列名1,列明2) values(?,?); connection cnn=getconn(); try{ preparedstatement prestmt =cnn.preparestement(sql); prestmt.setstring(1,值); prestmt.setstring(2,值);//或者:prestmt.setint(1,值); i=prestmt.executeupdate(); } catch (sqlexception e) { e.printstacktrace(); } return i;//返回影响的行数,1为执行成功 }
public int insert() { int i=0; string sql=insert into (表名)(列名1,列明2) values(?,?); connection cnn=getconn(); try{ preparedstatement prestmt =cnn.preparestement(sql); prestmt.setstring(1,值); prestmt.setstring(2,值);//或者:prestmt.setint(1,值); i=prestmt.executeupdate(); } catch (sqlexception e) { e.printstacktrace(); } return i;//返回影响的行数,1为执行成功 }
3. 更新操作
[java] view plaincopyprint?
public int update { int i=0; string sql=update (表名) set (列名1)=?,列明2=? where (列名)=?;//注意要有where条件 connection cnn=getconn(); try{ preparedstatement prestmt =cnn.preparestatement(sql); prestmt.setstring(1,(值)); prestmt.setstring(2,(值));//或者:prestmt.setint(1,值); prestmt.setint(3,(值)); i=prestmt.executeupdate(); } catch (sqlexception e) { e.printstacktrace(); } return i;//返回影响的行数,1为执行成功 }
public int update { int i=0; string sql=update (表名) set (列名1)=?,列明2=? where (列名)=?;//注意要有where条件 connection cnn=getconn(); try{ preparedstatement prestmt =cnn.preparestatement(sql); prestmt.setstring(1,(值)); prestmt.setstring(2,(值));//或者:prestmt.setint(1,值); prestmt.setint(3,(值)); i=prestmt.executeupdate(); } catch (sqlexception e) { e.printstacktrace(); } return i;//返回影响的行数,1为执行成功 }
4. 查找操作
[java] view plaincopyprint?
public string select { string sql = select * from (表名) where (列名)=(值); connection cnn = getconn();//此处为通过自己写的方法getconn()获得连接 try { statement stmt = conn.createstatement(); resultset rs = stmt.executequery(sql); if(rs.next()) { int m1 = rs.getint(1);//或者为rs.getstring(1),根据数据库中列的值类型确定,参数为第一列 string m2 = rs.getstring(2); } //可以将查找到的值写入类,然后返回相应的对象 } catch (sqlexception e) { e.printstacktrace(); } return (相应的值的变量); }
public string select { string sql = select * from (表名) where (列名)=(值); connection cnn = getconn();//此处为通过自己写的方法getconn()获得连接 try { statement stmt = conn.createstatement(); resultset rs = stmt.executequery(sql); if(rs.next()) { int m1 = rs.getint(1);//或者为rs.getstring(1),根据数据库中列的值类型确定,参数为第一列 string m2 = rs.getstring(2); } //可以将查找到的值写入类,然后返回相应的对象 } catch (sqlexception e) { e.printstacktrace(); } return (相应的值的变量); }
5. 删除操作
[java] view plaincopyprint?
public int delete() { string sql = delete from (表名) where (列名)=(值); int i=0; connection conn = getconn();//此处为通过自己写的方法getconn()获得连接 try { statement stmt = conn.createstatement(); i = stmt.executeupdate(sql); } catch (sqlexception e) { e.printstacktrace(); } return i;//如果返回的是1,则执行成功; }
