JDBC---1

其他 2019-01-30 15:01:49 阅读次数: 0 
package com.sxt.test;

import java.rmi.server.SocketSecurityException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JDBCTest1 {

	// 数据库服务器的地址
	private static String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
	// 连接服务器的用户名
	private static String user = "scott";
	// 连接服务器的用户密码
	private static String password = "tiger";

	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		// 第1步：加载驱动
		Class.forName("oracle.jdbc.driver.OracleDriver");
		// 第2步：创建连接,调用DriverManager.getConnection方法，返回一个连接对象Connection

		Connection conn = DriverManager.getConnection(url, user, password);
		// System.out.println(conn);
		// 第3步：创建SQL命令发送器,如果调用absolute()或last()来移动记录的指针，需要加入2个参数
		Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
		// 第4步：执行SQL命令(查询语句)，并返回结果
		ResultSet rs = stmt.executeQuery("select *  from dept");
		// 第5步：处理结果
		// next()方法将指针往下移动，如果当前行有记录返回true,否则返回false
		// absolute(int row)：将结果集的记录指针移动到第row行,row是从1开始
		rs.absolute(1);

		System.out.println(rs.getInt("deptno") + "..." + rs.getString("dname") + "..." + rs.getString("loc"));
        rs.last();
        System.out.println(rs.getInt("deptno") + "..." + rs.getString("dname") + "..." + rs.getString("loc"));
		// 第6步：关闭资源
		rs.close();
		stmt.close();
		conn.close();
	}
}



import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;

public class JDBCTest2 {
	// 数据库服务器的地址
	private static String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
	// 连接服务器的用户名
	private static String user = "scott";
	// 连接服务器的用户密码
	private static String password = "tiger";

	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		// 第1步：加载驱动
		Class.forName("oracle.jdbc.driver.OracleDriver");
		// 第2步：创建连接,调用DriverManager.getConnection方法，返回一个连接对象Connection

		Connection conn = DriverManager.getConnection(url, user, password);
		// System.out.println(conn);
		// 第3步：创建SQL命令发送器
		Statement stmt = conn.createStatement();
		Scanner sc = new Scanner(System.in);
		System.out.print("请输入部门编号:");
		int deptno = Integer.parseInt(sc.nextLine());
		System.out.print("请输入部门名称:");
		String dname = sc.nextLine();
		System.out.println("请输入部门地址:");
		String loc = sc.nextLine();
		// 第4步：执行SQL命令(插入语句)，并返回结果
		String sql="insert into dept values("+deptno+",'"+dname+"','"+loc+"')";
		int i = stmt.executeUpdate(sql);
		// 第5步：处理结果
		if (i > 0) {
			System.out.println("插入数据成功");
		} else {
			System.out.println("插入数据失败");
		}
		// 第6步：关闭资源
		stmt.close();
		conn.close();
	}
}

package com.sxt.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;
/**
 * 使用PreparedStatement实现添加数据
 * @author lujun
 *
 */
public class JDBCTest3 {
	// 数据库服务器的地址
	private static String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
	// 连接服务器的用户名
	private static String user = "scott";
	// 连接服务器的用户密码
	private static String password = "tiger";

	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		// 第1步：加载驱动
		Class.forName("oracle.jdbc.driver.OracleDriver");
		// 第2步：创建连接,调用DriverManager.getConnection方法，返回一个连接对象Connection

		Connection conn = DriverManager.getConnection(url, user, password);
		// System.out.println(conn);
		// 第3步：创建SQL命令发送器

		Scanner sc = new Scanner(System.in);
		System.out.print("请输入部门编号:");
		int deptno = Integer.parseInt(sc.nextLine());
		System.out.print("请输入部门名称:");
		String dname = sc.nextLine();
		System.out.println("请输入部门地址:");
		String loc = sc.nextLine();
		// 第4步：执行SQL命令(插入语句)，并返回结果
		String sql = "insert into dept values(?,?,?)";
		PreparedStatement stmt = conn.prepareStatement(sql);
		// 执行sql前要给每个?赋值
		stmt.setInt(1, deptno);
		stmt.setString(2, dname);
		stmt.setString(3, loc);
		int i = stmt.executeUpdate();
	/*	stmt.setInt(1, 24);
		
		stmt.setString(2, "xxx部");
		stmt.setString(3, "武汉");
		stmt.executeUpdate();*/
		// 第5步：处理结果
		if (i > 0) {
			System.out.println("插入数据成功");
		} else {
			System.out.println("插入数据失败");
		}
		// 第6步：关闭资源
		stmt.close();
		conn.close();
	}
}

package com.sxt.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;
/**
 * 使用PreparedStatement实现修改数据
 * @author lujun
 *
 */
public class JDBCTest4 {
	// 数据库服务器的地址
		private static String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
		// 连接服务器的用户名
		private static String user = "scott";
		// 连接服务器的用户密码
		private static String password = "tiger";

		public static void main(String[] args) throws ClassNotFoundException, SQLException {
			// 第1步：加载驱动
			Class.forName("oracle.jdbc.driver.OracleDriver");
			// 第2步：创建连接,调用DriverManager.getConnection方法，返回一个连接对象Connection

			Connection conn = DriverManager.getConnection(url, user, password);
			// System.out.println(conn);
			// 第3步：创建SQL命令发送器
			String sql="update  dept  set  dname=?,loc=? where deptno=?";
		   PreparedStatement  stmt=conn.prepareStatement(sql);
			// 执行sql前要给每个?赋值
		   stmt.setString(1, "市场2部");
		   stmt.setString(2, "南京");
		   stmt.setInt(3, 42);
			// 第4步：执行SQL命令(修改语句)，并返回结果
			int i = stmt.executeUpdate();
			// 第5步：处理结果
			if (i > 0) {
				System.out.println("修改数据成功");
			} else {
				System.out.println("修改数据失败");
			}
			// 第6步：关闭资源
			stmt.close();
			conn.close();
		}
}

package com.sxt.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
 * 使用PreparedStatement实现修改数据
 * @author lujun
 *
 */
public class JDBCTest5 {
	// 数据库服务器的地址
		private static String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
		// 连接服务器的用户名
		private static String user = "scott";
		// 连接服务器的用户密码
		private static String password = "tiger";

		public static void main(String[] args) throws ClassNotFoundException, SQLException {
			// 第1步：加载驱动
			Class.forName("oracle.jdbc.driver.OracleDriver");
			// 第2步：创建连接,调用DriverManager.getConnection方法，返回一个连接对象Connection

			Connection conn = DriverManager.getConnection(url, user, password);
			// System.out.println(conn);
			// 第3步：创建SQL命令发送器
			String sql="select *  from dept";
			PreparedStatement stmt = conn.prepareStatement(sql);
			// 第4步：执行SQL命令(查询语句)，并返回结果
			ResultSet rs = stmt.executeQuery();
			// 第5步：处理结果
			// next()方法将指针往下移动，如果当前行有记录返回true,否则返回false
			while (rs.next()) {
				// 获取当前行的每个列的数据
				int deptno = rs.getInt(1);
				String dname = rs.getString("dname");
				String loc = rs.getString("loc");
				System.out.println(deptno + "..." + dname + "..." + loc);
			}
			// 第6步：关闭资源
			rs.close();
			stmt.close();
			conn.close();
		}
}


package com.sxt.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;

public class JDBCTest6 {
	// 数据库服务器的地址
	private static String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
	// 连接服务器的用户名
	private static String user = "scott";
	// 连接服务器的用户密码
	private static String password = "tiger";

	/**
	 * 从键盘输入用户名和密码，判断用户是否登录成功
	 * 
	 * @param args
	 * @throws ClassNotFoundException
	 * @throws SQLException
	 */
	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		Scanner sc = new Scanner(System.in);
		System.out.print("请输入用户名：");
		String username = sc.nextLine();
		System.out.print("请输入密码：");
		String userpwd = sc.nextLine();

		Class.forName("oracle.jdbc.driver.OracleDriver");
		Connection conn = DriverManager.getConnection(url, user, password);

		// 创建Statement对象
		/*
		 * Statement stmt=conn.createStatement(); String
		 * sql="select *  from t_user where username='"
		 * +username+"' and userpassword='"+userpwd+"'";
		 */
		// 创建PreparedStatement对象
		String sql = "select *  from t_user where username=? and userpassword=?";
		PreparedStatement stmt = conn.prepareStatement(sql);
		stmt.setString(1, username);
		stmt.setString(2, userpwd);
		// System.out.println(sql);
		ResultSet rs = stmt.executeQuery();
		if (rs.next()) {
			System.out.println("登录成功");
		} else {
			System.out.println("登录失败");
		}
		// 关闭资源
		rs.close();
		stmt.close();
		conn.close();
	}
}

猜你喜欢

转载自blog.csdn.net/qq_41532872/article/details/86660694
今日推荐
周排行
AIZU 2224 Save your cats(并查集)
HTTP响应头状态码详解
Python socket编程（2）
MaxCompute Studio使用心得系列7—作业对比
Supervisor安装使用
LeetCode 164. Maximum Gap
mysql面试题: 一张表里面有ID自增主键，当insert了17条记录之后，删除了第15,16,17条记录，再把mysql重启，再insert一条记录，这条记录的ID是18还是15
nutch1.2 DeleteDuplicates IndexMerger 详解
OC - @property与setter,getter方法
SpringBoot @Transactional的rollbackFor属性
每日归档
更多
2024-09-19(0)
2024-09-18(0)
2024-09-17(0)
2024-09-16(0)
2024-09-15(0)
2024-09-14(0)
2024-09-13(0)
2024-09-12(0)
2024-09-11(0)
2024-09-10(0)

代码天地 © 2018 codetd.com

境外服务器   最新电视剧2022