package DB;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import Wisher.Wish;
//连接数据库的七个步骤
// 1: 载入JDBC驱动程序 ClassforName();
// 2: 定义链接URL String URL="";
// 3: 建立连接 Connection connection = DriverManager.getConnection();
// 4:创建语句对象 PreparedStatement PS=conn.prepareStatement(LOGIN);
// 5:执行查询或更新 ResultSet RS = ps.executeQuery();
// 6:处理结果
// 7:记得要关闭连接 this.close(RS, PS, connection);
public class DBConnection {
private static final String INSERT = "insert into wish(username,contents,time,ip) values(?,?,?,?)";
private static final String DELETE = "delete from wish where id=?";
private static final String LOGIN = "select password from admin where username=?";
private static Connection getConnection(){
//创建数据库连接
Connection conn=null;
//结果集、用来存放数据库的查询结果、操纵数据的功能
//ResultSet rs=null;
//准备数据库语句
//PreparedStatement ps=null;
try {
//加载驱动
Class.forName("org.gjt.mm.mysql.Driver");
String url="jdbc:mysql://127.0.0.1:3306/practise";
String id="root";
String pw="";
//连接数据库使用已经定义的账号和密码
conn = DriverManager.getConnection(url, id, pw);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return conn;
}
public String insert(String username,String contents,String time,String ip) {
//创建一个数据库连接调用UserService类里面的getConnection方法
Connection conn = null;
conn = DBConnection.getConnection();
//结果集、用来存放数据库的查询结果、操纵数据的功能
ResultSet rs = null;
//准备数据库语句
PreparedStatement ps = null;
Wish u = new Wish();
try {
//准备连接数据库的语句
System.out.println("数据库中的用户名是:"+username);
System.out.println(contents);
System.out.println(time);
System.out.println(ip);
ps=conn.prepareStatement(INSERT);
ps.setString(1, username);
ps.setString(2, contents);
ps.setString(3, time);
ps.setString(4, ip);
int i = ps.executeUpdate();
System.out.println("\n\ni="+i+"\n\n");
return "success";
} catch (SQLException e) {
e.printStackTrace();
return "error";
} finally {
this.close(rs, ps, conn);
}
}
public String delete(int getid) {
//创建一个数据库连接调用UserService类里面的getConnection方法
Connection conn = null;
conn = DBConnection.getConnection();
//结果集、用来存放数据库的查询结果、操纵数据的功能
ResultSet rs = null;
//准备数据库语句
PreparedStatement ps = null;
try {
//准备连接数据库的语句
System.out.println("数据库当中的ID为:"+getid);
ps=conn.prepareStatement(DELETE);
//
ps.setInt(1, getid);
//执行数据库的语句
// rs = ps.executeQuery();
int i = ps.executeUpdate();
System.out.println("\n\ni="+i+"\n\n");
if(i==1)
return "success";
else
return "error";
} catch (SQLException e) {
e.printStackTrace();
return "error";
} finally {
this.close(rs, ps, conn);
}
}
public String login(String username) {
//创建一个数据库连接调用UserService类里面的getConnection方法
Connection conn = null;
conn = DBConnection.getConnection();
//结果集、用来存放数据库的查询结果、操纵数据的功能
ResultSet rs = null;
//准备数据库语句
PreparedStatement ps = null;
String a=null;
try {
//准备连接数据库的语句
ps=conn.prepareStatement(LOGIN);
//
ps.setString(1, username);
//执行数据库的语句
rs = ps.executeQuery();
//
if (rs.next()) {
a=rs.getString("password");
System.out.println(a);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
this.close(rs, ps, conn);
}
return a;
}
public String getLocalIP(){
InetAddress addr = null;
try {
addr = InetAddress.getLocalHost();
} catch (UnknownHostException e) {
e.printStackTrace();
return null;
}
byte[] ipAddr = addr.getAddress();
String ipAddrStr = "";
for (int i = 0; i < ipAddr.length; i++) {
if (i > 0) {
ipAddrStr += ".";
}
ipAddrStr += ipAddr[i] & 0xFF;
}
//System.out.println(ipAddrStr);
return ipAddrStr;
}
private void close(ResultSet rs, PreparedStatement ps, Connection conn) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (ps != null) {
try {
ps.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
许愿墙 struts jsp 毕业设计
4星 · 超过85%的资源 需积分: 10 54 浏览量
2011-06-09
14:57:09
上传
评论 1
收藏 4.97MB RAR 举报
leo19870706
- 粉丝: 29
- 资源: 2
最新资源
- mybatis中的动态sql, 涉及 where trim set if foreach等
- 简单- 快递运输(Java & JS & Python & C).html
- mybatis框架 更改ems系统,使用动态sql等.zip
- 易语言工具条下拉菜单实现
- Mybatis动态SQL高级映射.zip
- 源码esp8266开发板机智云机智云智能灯
- Python实现多图像转换成连贯的PDF文件,支持所有图片格式,可预览、裁剪、自定义PDF布局、设置图像顺序、PDF质量选择等
- H5腾讯地图选择位置组件
- 基于UCC28019+LM5017电源板硬件(原理图+PCB)工程文件.zip
- 源码esp8266开发板机智云机智云空气净化器
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
- 1
- 2
前往页