package com.neusoft;
import java.sql.Connection;
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Scanner;public class MainProgram {
/**
* @param args */ /** * 需求是:1:输入a添加用户信息2：输入b查询所有用户信息3：输入c删除一个用户信息4：输入d更新一个用户信息5：输入e退出程序 * 要一步一步的输入，直到输入e结束本程序 * 运行本程序之前请确保一下连个条件 1：你的oracle数据库里先建好users表，表里面有两列id，number类型；name，varchar2(20); sql语句: CREATE TABLE users ( ID NUMBER PRIMARY KEY, NAME varchar2(20) ); 2：确认一下你的oracle数据库，我的oracle端口是1521，用户名：hr，密码：hr。你连接数据库的时候注意一下你的数据库信息 3：本程序还有不足，请大神指教，联系QQ：136304953 微博：； */ public static void main(String[] args) { // TODO Auto-generated method stub System.out.println("本程序主要功能是：\n" + "1:输入a添加用户信息\n" + "2：输入b查询所有用户信息\n" + "3：输入c删除一个用户信息\n" + "4：输入d更新一个用户信息\n" + "5：输入e退出程序\n"); System.out.println("请输入你所有选择的功能："); Scanner input = new Scanner(System.in);//输入所要选择的功能 if ("a".equals(input.next())) {//输入a后添加用户信息 System.out.println("请输入你要添加用户的id："); Scanner ipt = new Scanner(System.in); int id = ipt.nextInt();try {
Class.forName("oracle.jdbc.driver.OracleDriver");//加载数据库驱动 String url = "jdbc:oracle:thin:@localhost:1521:oracle";//定义连接的数据库 Connection conn = DriverManager.getConnection(url, "hr", "hr");//连接数据库 String sql = "insert into users values(?,?)";//定义sql语句 PreparedStatement ps = conn.prepareStatement(sql);//预编译sql语句 ps.setInt(1, id); ps.setString(2, "宝贝"); if (ps.executeUpdate() > 0) {//判断sql语句是否执行成功 System.out.println("添加用户id:" + id + "的信息成功"); } ps.close();//退出预编译 conn.close();//退出数据库连接} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }}
if ("b".equals(input.next())) {//输入b后显示用户的信息 try { Class.forName("oracle.jdbc.driver.OracleDriver"); String url = "jdbc:oracle:thin:@localhost:1521:oracle"; Connection conn = DriverManager.getConnection(url, "hr", "hr"); String sql = "select *from users"; PreparedStatement ps = conn.prepareStatement(sql); ResultSet rs = ps.executeQuery(); while (rs.next()) { int id = rs.getInt("id"); String name = rs.getString("name"); System.out.println(id + ":" + name);}
rs.close(); ps.close(); conn.close(); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }}
if ((input.next()).equals("c")) {//输入c后删除用户的信息 try { System.out.println("请你输入要删除用户的id："); Scanner input1 = new Scanner(System.in); int id = input1.nextInt(); Class.forName("oracle.jdbc.driver.OracleDriver"); String url = "jdbc:oracle:thin:@localhost:1521:oracle"; Connection conn = DriverManager.getConnection(url, "hr", "hr"); String sql = "delete from users where id=?"; PreparedStatement ps = conn.prepareStatement(sql); ps.setInt(1, id); if (ps.executeUpdate() > 0) { System.out.println("删除用户成功！！！"); } ps.close(); conn.close();} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }}
if ((input.next()).equals("d")) {//输入d后修改用户的信息 System.out.println("请输入要修改用户的id："); Scanner input2 = new Scanner(System.in); int id = input2.nextInt();try {
Class.forName("oracle.jdbc.driver.OracleDriver"); String url = "jdbc:oracle:thin:@localhost:1521:oracle"; Connection conn = DriverManager.getConnection(url, "hr", "hr"); String sql = "update users set name=? where id=?"; PreparedStatement ps = conn.prepareStatement(sql); ps.setString(1, "妹妹"); ps.setInt(2, id); if (ps.executeUpdate() > 0) { System.out.println("修改用户id=" + id + "的信息成功"); } ps.close(); conn.close();} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }}
if ((input.next()).equals("e")) {//输入e后退出本程序 System.exit(0);}
}
}