SQL练习

记得导包

/class TestUser

package com.JDBCsql;

import lombok.Data;

@Data
public class TestUser {
    private Integer id;
    private String name;
    private Integer pasword;
    private String mail;
    private String root;
}

　　/class TestMysql

package com.JDBCsql;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

public class TestMysql {
       private static String DRIVER=null;
       private static String URL=null;
       private static  String USERNAME = null;
   	   private static  String PASSWORD = null;
   	static{
		try {
			FileInputStream fis
			= new FileInputStream("src/db.properties");
			Properties pt = new Properties();
			pt.load(fis);
			DRIVER = pt.getProperty("DRIVER");
			URL = pt.getProperty("URL");
			USERNAME = pt.getProperty("USERNAME");
			PASSWORD = pt.getProperty("PASSWORD");
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
   	public static Connection getConn(){
		Connection conn=null;
		try {
			/*加载驱动*/
//			System.out.println(DRIVER);
			Class.forName(DRIVER);
			/*连接数据库*/
			conn= DriverManager.getConnection(URL, USERNAME, PASSWORD);

		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return conn;
	}
	//关闭连接
	public static void close(Connection conn){
		try {
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}
	//关闭连接
	public static void close(PreparedStatement ps){
		try {
			ps.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}
	//关闭连接
	public static void close(ResultSet rs){
		try {
			rs.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

	public static int executeUpdate(String sql,Object... papram) {
		// TODO Auto-generated method stub
		Connection conn =getConn();
		int result=0;
		try {
			PreparedStatement pst = conn.prepareStatement(sql);
			if (papram!=null) {
				for (int i = 0; i < papram.length; i++) {
					pst.setObject(i+1, papram[i]);
				}
			}
			result =pst.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			close(conn);
		}
		return result;

	}

}

　　/class TestMenu

package com.JDBCsql;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

public class TestMenu {

     public static int show(Scanner scanner,TestUser testUser1,String a4) {
    	System.out.println("查询全部用户-----------------1");
 		System.out.println("根据ID查询用户………………………………………2");
 		System.out.println("根据姓名查询用户--------------3");
 		System.out.println("请输入要做的操作：");
 		int d=scanner.nextInt();
 		switch (d) {
		case 1:
			getUser1(testUser1);

			RootUser.show(a4, scanner, testUser1);
			break;
        case 2:

        	getUser2(testUser1, scanner);
        	System.out.println(testUser1.toString());
        	System.out.println("=========================================");
			RootUser.show(a4, scanner, testUser1);
			break;
        case 3:
        	getUser3(testUser1, scanner);
        	System.out.println(testUser1.toString());
			System.out.println("=========================================");
			RootUser.show(a4, scanner, testUser1);
			break;
		default:
			break;
		}
		return d;
	}
     public static int getUser1(TestUser testUser1){
 		Connection conn = 	TestMysql.getConn();
 		List<TestUser>list=new ArrayList<TestUser>();
 		ResultSet index ;//记录行数
 		PreparedStatement pst = null;
 		String sql =  "select * from user ";
 		try {
 			pst = conn.prepareStatement(sql);

 			index = pst.executeQuery();
 			while (index.next()) {
 				TestUser testUser=new TestUser();
 				testUser.setId(index.getInt("id"));
 				testUser.setName(index.getString("name"));
 				testUser.setPasword(index.getInt("pasword"));
 				testUser.setMail(index.getString("mail"));
 				testUser.setRoot(index.getString("root"));
 				list.add(testUser);
 			}	

 			for (TestUser testUser2 : list) {
				System.out.println(testUser2.getId()+" "+testUser2.getName()+" "+testUser2.getPasword()+" "+testUser2.getMail()+" "+testUser2.getRoot());
				System.out.println("=========================================");
			}
 		} catch (SQLException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
 		}finally {
 			try {
 				pst.close();
 				conn.close();
 			} catch (SQLException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
 			}

 		}
		return 0;

 	}
     public static int getUser2(TestUser testUser1,Scanner scanner){
 		Connection conn = 	TestMysql.getConn();
 		ResultSet index ;//记录行数
 		PreparedStatement pst = null;
 		System.out.println("请输入要查询的ID:");
    	String s=scanner.next();
    	testUser1.setId(Integer.valueOf(s));
 		String sql =  "select * from user where id=‘"+testUser1.getId()+"‘";
 		try {
 			pst = conn.prepareStatement(sql);

 			index = pst.executeQuery();
 			while (index.next()) {
 				testUser1.setId(index.getInt("id"));
 				testUser1.setName(index.getString("name"));
 				testUser1.setPasword(index.getInt("pasword"));
 				testUser1.setMail(index.getString("mail"));
 				testUser1.setRoot(index.getString("root"));
 			}
 		} catch (SQLException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
 		}finally {
 			try {
 				pst.close();
 				conn.close();
 			} catch (SQLException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
 			}

 		}
		return 0;

 	}
     public static int getUser3(TestUser testUser1,Scanner scanner){
 		Connection conn = 	TestMysql.getConn();
 		ResultSet index ;//记录行数
 		System.out.println("请输入要查询的用户名:");
 		String s=scanner.next();
 		testUser1.setName(s);
 		PreparedStatement pst = null;
 		String sql =  "select * from user where name=‘"+testUser1.getName()+"‘";
 		try {
 			pst = conn.prepareStatement(sql);

 			index = pst.executeQuery();
 			while (index.next()) {
 				testUser1.setId(index.getInt("id"));
 				testUser1.setName(index.getString("name"));
 				testUser1.setPasword(index.getInt("pasword"));
 				testUser1.setMail(index.getString("mail"));
 				testUser1.setRoot(index.getString("root"));
 			}
 		} catch (SQLException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
 		}finally {
 			try {
 				pst.close();
 				conn.close();
 			} catch (SQLException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
 			}

 		}
 		return 0;
 	}
}

　　/class PublicUser

package com.JDBCsql;

import java.util.Scanner;
import com.JDBCsql.TestUser;
public class PublicUser {

	public static int show(String a4,Scanner scanner,TestUser testUser1){
    	System.out.println("登录成功。。。。");
		System.out.println("======================");
		System.out.println("欢迎登录主窗体");
		System.out.println(a4+"您好"+"    "+"您的权限是"+testUser1.getRoot());
		System.out.println("======================");
		System.out.println("修改自己的信息---------------1");
		System.out.println("查询自己的信息………………………………………2");
		System.out.println("退出主程序------------------3");
		int d=scanner.nextInt();
		switch (d) {
		case 1:
			System.out.println("请输入您的新用户名：");
			String q=scanner.next();

			testUser1.setName(q);
			System.out.println("请输入您的新密码：");
			String q1=scanner.next();
			testUser1.setPasword(Integer.valueOf(q1));
			System.out.println("请输入您的新邮箱：");
			String q3=scanner.next();
			testUser1.setMail(q3);
		    testUser1.getId();
			update1(testUser1);
			System.out.println("信息修改成功！");
			PublicUser.show(a4, scanner, testUser1);
			break;

		case 2:
			System.out.println("您的用户名为："+testUser1.getName()+"您的用户密码是："+testUser1.getPasword()+"您的邮箱是："+testUser1.getMail()+"您的权限是:"+testUser1.getRoot());
			PublicUser.show(a4, scanner, testUser1);
			break;

		default:
			break;
		}
		return d;
    }

	private static int update1(TestUser testUser1) {
		// TODO Auto-generated method stub
		return TestMysql.executeUpdate("update user set name=?,pasword=?,mail=?where id=?",testUser1.getName(),testUser1.getPasword(),testUser1.getMail(),testUser1.getId());
	}
}

　　/class RootUser

package com.JDBCsql;

import java.util.Scanner;

public class RootUser {
	public static int show(String a4,Scanner scanner,TestUser testUser1){
    	System.out.println("登录成功。。。。");
		System.out.println("======================");
		System.out.println("欢迎登录主窗体");
		System.out.println(a4+"您好"+"    "+"您的权限是"+"管理员");
		System.out.println("======================");
		System.out.println("添加用户---------------1");
		System.out.println("删除用户………………………………………2");
		System.out.println("修改用户---------------3");
		System.out.println("查询用户………………………………………4");
		System.out.println("退出程序---------------5");
		int d=scanner.nextInt();
		switch (d) {
		case 1:
			System.out.println("请输入您想要创建的用户名：");
			String q=scanner.next();
			testUser1.setName(q);
			System.out.println("请输入您想要创建的用户密码：");
			String q1=scanner.next();
			testUser1.setPasword(Integer.valueOf(q1));
			System.out.println("请输入新用户的邮箱：");
			String q3=scanner.next();
			testUser1.setMail(q3);
			String q4="管理员";
			testUser1.setRoot(q4);
			add(testUser1);
			System.out.println("新用户创建成功！");
			RootUser.show(a4, scanner, testUser1);
			break;

		case 4:
			TestMenu.show(scanner, testUser1, a4);
//			RootUser.show(a4, scanner, testUser1);
			break;
        case 2:
        	System.out.println("请输入您想要删除用户的ID：");
			String q5=scanner.next();
			testUser1.setId(Integer.valueOf(q5));
			delete(Integer.valueOf(q5));
			System.out.println("用户删除成功！");
			RootUser.show(a4, scanner, testUser1);
        	break;
        case 3:
        	System.out.println("请输入您想要修改的用户ID：");
			String v=scanner.next();
			testUser1.setId(Integer.valueOf(v));
        	System.out.println("请输入您想要修改的用户名：");
			String v1=scanner.next();
			testUser1.setName(v1);
			System.out.println("请输入您想要修改的用户密码：");
			String v2=scanner.next();
			testUser1.setPasword(Integer.valueOf(v2));
			System.out.println("请输入您想要修改的用户的邮箱：");
			String v3=scanner.next();
			testUser1.setMail(v3);
			System.out.println("请输入您想要修改的用户的权限(管理员/普通用户)：");
			String v4=scanner.next();
			testUser1.setRoot(v4);
			update(testUser1);
			System.out.println("新用户创建成功！");
			RootUser.show(a4, scanner, testUser1);
        	break;
		default:
			break;
		}
		return d;
    }

	private static int update(TestUser testUser1) {
		// TODO Auto-generated method stub
		return TestMysql.executeUpdate("update user set name=?,pasword=?,mail=?,root=? where id=?",testUser1.getName(),testUser1.getPasword(),testUser1.getMail(),testUser1.getRoot(),testUser1.getId());
	}

	private static int delete(Integer q5) {
		// TODO Auto-generated method stub
		return TestMysql.executeUpdate("delete from user where id=?",q5);
	}

	private static int add(TestUser testUser1) {
		// TODO Auto-generated method stub
		return TestMysql.executeUpdate("insert into user (name,pasword,mail,root) values (?,?,?,?)",testUser1.getName(),testUser1.getPasword(),testUser1.getMail(),testUser1.getRoot());
	}

}

　　/class TestView

package com.JDBCsql;

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

public class TestView {
	public static int delete(int id){
		return TestMysql.executeUpdate("delete from user where id=?",id);

	}
	public static int update(TestUser testUser){
		return TestMysql.executeUpdate("update user set name=?,pasword=?,mail=?,root=? where id=?",testUser.getName(),testUser.getPasword(),testUser.getMail(),testUser.getRoot(),testUser.getId());
	}
	public static int update1(TestUser testUser){
		return TestMysql.executeUpdate("update user set name=?,pasword=?,mail=?where id=?",testUser.getName(),testUser.getPasword(),testUser.getMail(),testUser.getId());
	}
	public static int add(TestUser testUser){
		return TestMysql.executeUpdate("insert into user (name,pasword,mail,root) values (?,?,?,?)",testUser.getName(),testUser.getPasword(),testUser.getMail(),testUser.getRoot());
	}
	public static TestUser getUser(TestUser testUser){
		Connection conn = 	TestMysql.getConn();
		TestUser testUser4 =new TestUser();
		ResultSet index ;//
		PreparedStatement pst = null;
		String sql =  "select * from user where name=‘"+testUser.getName()+"‘ and pasword=‘"+testUser.getPasword()+"‘";
		try {
			pst = conn.prepareStatement(sql);

			index = pst.executeQuery();
			if (index.next()==false) {
				return new TestUser();
			}
			else {
				testUser4.setId(index.getInt("id"));
				testUser4.setName(index.getString("name"));
				testUser4.setPasword(index.getInt("pasword"));
				testUser4.setMail(index.getString("mail"));
				testUser4.setRoot(index.getString("root"));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			try {
				pst.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}
		return testUser4;
	}
	public static void main(String[] args) {
		System.out.println("欢迎使用neusoft用户管理系统");
		System.out.println("======================");
		System.out.println("用户注册----------------1");
		System.out.println("用户登录----------------2");
		System.out.println("退出系统----------------3");
		Scanner scanner=new Scanner(System.in);
		int key = scanner.nextInt();
		switch (key) {
		case 2:
			System.out.println("欢迎");
			System.out.println("======================");
			System.out.println("");
			String a1=scanner.next();
			TestUser testUser =new TestUser();
			testUser.setName(a1);
			System.out.println("输入用户名");
			String a2=scanner.next();
			testUser.setPasword(Integer.valueOf(a2));
			System.out.println("输入邮箱");
			String a3=scanner.next();
			testUser.setMail(a3);
			System.out.println("输入权限");
			String a7=scanner.next();
			testUser.setRoot(a7);
			add(testUser);
			System.out.println("");
			TestView.main(args);
			break;
		case 1:
			System.out.println("");
			System.out.println("======================");
			System.out.println("");
			String a4=scanner.next();
			TestUser testUser1 =new TestUser();
			testUser1.setName(a4);
			System.out.println("?");
			int a5=scanner.nextInt();
			testUser1.setPasword(a5);
			testUser1=TestView.getUser(testUser1);
			if (testUser1==null) {
				System.out.println("");
			} else if (testUser1.getRoot().equals("")==true) {
				PublicUser.show(a4, scanner, testUser1);
			}else  {
				RootUser.show(a4, scanner, testUser1);
			}

			break;

		default:
			scanner.close();
			break;
		}
	}
}

　　

时间： 2024-04-01 16:13:39

SQL练习的相关文章

SQL查询字段添加括号报错：Operand should contain 1 column(s)

SQL语句:查询连个字段的信息 SELECT (menu_id,menu_captions) FROM bsdb.menulist a WHERE a.menu_id like ('2_'); 然后,因为这是在存储过程中的一个语句所以,在执行存储过程的时候编译不会报错,但是执行的时候却汇报错:Operand should contain 1 column(s):原因不好解释: 下面是官方发解释(MYSQL):https://dev.mysql.com/doc/refman/5.0/en/row-

SQL Server 2008的MSSQLSERVER 请求失败或服务未及时响应

我的是SQL server 2008R2, 以前可以正常的启动SQL server(SQLEXPRESS).SQL server(MSSQLSERVER),有几天没有打开了,就在昨天 开机之后就无法启动MSSQLSERVER了,提示的信息如下图: 快速解决办法如下: 第一步:打开事件查看器,查看windows日志,点击应用程序,查看windows错误日志 http://product.pconline.com.cn/itbk/software/win8/1211/3060037.html 第二步

【Kettle】4、SQL SERVER到SQL SERVER数据转换抽取实例

1.系统版本信息 System:Windows旗舰版 Service Pack1 Kettle版本:6.1.0.1-196 JDK版本:1.8.0_72 2.连接数据库 本次实例连接数据库时使用全局变量. 2.1 创建新转换:spoon启动后,点击Ctrl+N创建新转换 2.2 在新转换界面中,右键点击DB连接,系统会弹出[数据库连接]界面. windows系统环境下,可用${}获取变量的内容. 说明: 连接名称:配置数据源使用名称.(必填) 主机名称:数据库主机IP地址,此处演示使用本地IP(

sql常用格式化函数及字符串函数

一.常用格式化函数 1.日期转字符串 select to_char(current_timestamp, 'YYYY-MM-DD HH24:MI:SS') //2017-09-18 22:41:50 YYYY:年(4和更多位) MM:月份号(01-12) DD:一个月里的日(01-31) HH24:一天的小时数(00-23) MI:分钟(00-59) SS:秒(00-59) 2.字符串转日期 select to_date('2017-09-18','YYYY-MM-DD') //2017-09-

Bootstrap + AngularJS+ Ashx + SQL Server/MySQL

去年年底12月,为适应移动端浏览需求,花了1个月时间学习Bootstrap,并将公司ASP网站重构成ASP.NET. 当时采取的网站架构: Bootstrap + jQuery + Ashx + SQL Server 时间紧,没人带,只能硬着头皮,最后如期完成,但是也遗留了几个问题. 问题: 1.页面查询条件太复杂,太多的checkbox,jQuery操作DOM虽然方便,但是组合成json提交给后端还是比较麻烦,有没有天然支持json的前端框架或者脚本语言? html控件做的任何修改,都自动保存

Spark SQL 之 Join 实现

原文地址:Spark SQL 之 Join 实现 Spark SQL 之 Join 实现 涂小刚 2017-07-19 217标签: spark , 数据库 Join作为SQL中一个重要语法特性,几乎所有稍微复杂一点的数据分析场景都离不开Join,如今Spark SQL(Dataset/DataFrame)已经成为Spark应用程序开发的主流,作为开发者,我们有必要了解Join在Spark中是如何组织运行的. SparkSQL总体流程介绍 在阐述Join实现之前,我们首先简单介绍SparkSQL

PL/SQL developer 连接oracle数据库报错“initialization error could not load oci.dll”

声明:PL/SQL 版本:PL/SQL Developer 9.0.6 (http://files.allroundautomations.com/plsqldev906.exe) 报错提示如图: 原因:PL/SQL只对32位OS进行支持,解决方法是额外加载一个oci.dll文件 解决办法:1.下载OCI.DLL相关库文件.地址: (需注册Oracle账号) http://www.oracle.com/technetwork/topics/winsoft-085727.html ----->  

WAF——针对Web应用发起的攻击，包括但不限于以下攻击类型：SQL注入、XSS跨站、Webshell上传、命令注入、非法HTTP协议请求、非授权文件访问等

核心概念 WAF Web应用防火墙(Web Application Firewall),简称WAF. Web攻击 针对Web应用发起的攻击,包括但不限于以下攻击类型:SQL注入.XSS跨站.Webshell上传.命令注入.非法HTTP协议请求.非授权文件访问等.

sql

use simulation; # 多条SQL语句必须以分号分隔 show DATABASES ; show TABLES ; show COLUMNS from customers; # SQL语句不区分大小写 SHOW COLUMNS FROM products; SHOW COLUMNS FROM vendors; SHOW COLUMNS FROM orders; SHOW COLUMNS FROM productnotes; SHOW COLUMNS FROM orderitems;

MyBatis学习（四）XML配置文件之SQL映射的XML文件

SQL映射文件常用的元素: 1.select 查询语句是MyBatis最常用的语句之一. 执行简单查询的select元素是非常简单的: <select id="selectUser" parameterType="int" resultType="hashmap"> SELECT * FROM PERSON WHERE ID = #{id} </select> 这个语句被称作selectUser,接受一个int类型的参数,