SqlServer数据库基础——使用JDBC对表增删改查

使用的IDE：Intellj idea 13.1

数据库中表的增删改查

1、连接sqlServer数据库

<span style="white-space:pre">		</span>static Connection conn;

<span style="white-space:pre">		</span>//static PreparedStatement st;

<span style="white-space:pre">		</span>static java.sql.Statement stat;

		String url = "jdbc:sqlserver://EE-LAB; DatabaseName=Fantastic FourMen";
		String name = "user";
		String passWord = "123456";

		//Connection con=null;
		//java.sql.Statement stat=null;
		//ResultSet rs=null;

		try {
			//Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
			Class.forName("com.microsoft.sqlserver.jdbc.sqlServerDriver");
			System.out.println("驱动程序加载");
			System.out.println("即将连接到数据库");
		} catch (ClassNotFoundException e) {
			System.out.println("无法加载驱动程序" + e.getMessage());
			e.printstacktrace();
			return;
		}

		conn = DriverManager.getConnection(url,name,passWord);

		conn.close();

2、增加数据

	public static void insertData(String insertsql) {

		try {
			//String sql = Format("SET NOCOUNT ON "+ insertsql);
			stat = conn.createStatement();
			//ResultSet rs = stat.executeQuery(insertsql);
			int count = stat.executeUpdate(insertsql);  //用这个代替ResultSet rs = stat.executeQuery(insertsql); 同样可以插入
			System.out.println("成功插入" + count + "行");
			//rs.close();
			stat.close();

		} catch (sqlException e) {
			System.out.println("数据插入失败");
			e.printstacktrace();

		}

	}

3、删除数据

	private static void deleteData() {
		String deletesql = "DELETE FROM new_table " + "WHERE ID = 5 ";
		try {
			stat = conn.createStatement();
			int count = stat.executeUpdate(deletesql);
			stat.close();
			System.out.println("删除了" + count + "条数据");
		} catch (sqlException e) {
			System.out.println("数据删除失败");
			e.printstacktrace();
		}

	}

4、修改数据

	private static void upData() {
		String updatesql = "UPDATE testTable SET age = 5 WHERE name ='ling'";
		try {
			stat = conn.createStatement();
			int count = stat.executeUpdate(updatesql);
			stat.close();
		} catch (sqlException e) {
			System.out.println("数据修改失败");
			e.printstacktrace();
		}
	}

5、查询数据

	public static void serchData(String serchsql) {
		try {
			stat = conn.createStatement();
			ResultSet rs = stat.executeQuery(serchsql);
			System.out.println("查询结果：");
			while (rs.next()) {
				System.out.println(rs.getString(1) + " " + rs.getString(2) + " " + rs.getString(3) + " " + rs.getString(4));
			}
			rs.close();
			stat.close();


		} catch (sqlException e) {
			System.out.println("查询失败");
			e.printstacktrace();
		}

	}

6、创建新表，并添加另外一个表的数据

	private static void createInsertNewTable() {
		String serchsql = "select * from new_table";//创建新表
		String insertsql = "insert into new_table" + " select name,age,sex " + "from testTable";//将testTable表中的数据插入到新表中
		createTable("new_table");  //创建一张新表
		insertData(insertsql); //插入数据
		serchData(serchsql);  //查找数据
	}

	private static void createTable(String tableName) {
		String createTablesql = "create table " + tableName + " (ID int primary key,name ntext,age int,sex nchar(10))";
		//System.out.println(createTablesql);
		try {
			stat = conn.createStatement();
			int count = stat.executeUpdate(createTablesql);
			stat.close();
			//ResultSet rs = stat.executeQuery(createTablesql);
			//rs.close();
		} catch (sqlException e) {
			System.out.println(tableName + "创建失败");
			e.printstacktrace();
		}
	}