代码详解
package jdbcDemo;
import java.sql.Statement;
import javax.naming.spi.DirStateFactory.Result;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
public class ConnectJdbc {
Connection conn =null;
public static void main(String[] args) throws Exception {
ConnectJdbc cj = new ConnectJdbc();
cj.getCon();
//新增表
//cj.addTable();
//删除表
// cj.deleteTable();
// 查询
cj.queryData();
//删除
//cj.deleteData(4456);
//更新
//cj.updateData(4456);
//新增
//cj.addData(4467, "Jake",5000);
cj.closeCon();
}
//连接数据库
public Connection getCon() throws Exception {
//加载驱动
Class.forName("oracle.jdbc.OracleDriver");
//获得连接
//参数1 数据库地址
//参数2 数据库用户名
//参数3 密码
conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl",
"scott","root");
return conn;
}
//关闭数据库连接
public void closeCon() throws Exception {
conn.close();
}
//新增表
public void addTable() throws Exception {
// 创建Statement对象 此对象帮我们执行sql
Statement st = conn.createStatement();
//写sql
String sql = "create table utable(name varchar(20),pwd char(6))";
//执行新增表语句,返回值为0
int rs = st.executeUpdate(sql);
System.out.println(rs);
if(rs==0) {
System.out.println("创建用户表成功");
}
}
//删除表
public void deleteTable() throws Exception {
// 创建Statement对象 此对象帮我们执行sql
Statement st = conn.createStatement();
//写sql
String sql = "drop table utable";
//执行删除表语句,返回值为0
int rs = st.executeUpdate(sql);
System.out.println(rs);
if(rs==0) {
System.out.println("用户表删除成功");
}
}
//查询
public void queryData() throws Exception {
// 创建Statement对象 此对象帮我们执行sql
Statement st = conn.createStatement();
//写sql
String sql = "select * from emp";
//查询,返回结果集,存放返回的数据集合
ResultSet rs = st.executeQuery(sql);
while(rs.next()) {
//取出一个字段,由于表中的empno为number,所以调用getInt()
//由于ename为varchar2,所以调用getString()
System.out.println(rs.getInt("empno")+" "+rs.getString("ename"));
}
}
//删除
public void deleteData(int id) throws Exception {
// 创建Statement对象 此对象帮我们执行sql
Statement st = conn.createStatement();
//写sql
String sql = "delete from emp where empno="+id;
//删除,返回值为删除的行数
int rs = st.executeUpdate(sql);
if(rs>0) {
System.out.println("删除成功");
}
}
//更新
public void updateData(int id) throws SQLException {
// 创建Statement对象 此对象帮我们执行sql
Statement st = conn.createStatement();
//写sql
String sql = "update emp set sal=5000 where empno="+id;
//更新的行数
int rs = st.executeUpdate(sql);
if(rs>0) {
System.out.println("更新成功");
}
}
//新增
public void addData(int empno,String ename,double salary) throws Exception {
// 创建Statement对象 此对象帮我们执行sql
Statement st = conn.createStatement();
//写sql
String sql = "insert into emp(empno,ename,sal) values("+empno+",'"+ename+"',"+salary+")";
//新增的行数
int rs = st.executeUpdate(sql);
if(rs>0) {
System.out.println("新增成功");
}
}
}
JDBC
JDBC 数据库连接技术
java database connectivity
使用数据库连接技术,需要jar包
java 可以连接不同的数据库,但连接不同的数据库需要不同的jar包
eclipse导入jar包
1.在java项目中连接JDBC
1.新建java project项目,在该项目下建个文件夹,我的是jar,然后把jar包放入该文件夹下
2.把jar包导入java项目
导入成功
2.在web项目中,导入jar包
add to path后生成这个refered libraries文件夹
免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://yundeesoft.com/5300.html