泛型(Generic)的本质是类型参数化,通俗的说就是用一个占位符来表示类型,这个类型可以是String,Integer等不确定的类型,表明可接受的类型。

泛型是Java中一个非常重要的知识点,在Java集合类框架中泛型被广泛应用。

在数据结构中有一种结构叫:,它的特点是:先进后出,后进先出

如:放衣服的箱子,糖葫芦

现在来模拟一个栈的数据结构

  1. package com.nf.math;
  2. public class ObjUtil {
  3. public static void main(String[] args) {
  4. Stack stack=new Stack();
  5. stack.push(11);
  6. stack.push(22);
  7. stack.push(55);
  8. int data=stack.pop();
  9. System.out.println(data);
  10. System.out.println(stack.pop());
  11. System.out.println(stack.pop());
  12. }
  13. }
  14. class Stack{
  15. //用于存放数据的数组
  16. private int[] data=new int[10];
  17. //当前下标
  18. private int i=0;
  19. //进栈
  20. public void push(int obj){
  21. data[i++]=obj;
  22. }
  23. //出栈
  24. public int pop(){
  25. return data[--i];
  26. }
  27. }

结果:

  1. 55
  2. 22
  3. 11

缺点是不通用

版本一有明显的缺点,只允许存放int类型的数据,如果需要其它类型的数据怎么办法?

有人提议重新创建不同类型的栈,这样不好,因为如果需要10种不同类型的栈,则需定义10个,维护也麻烦。

使用Object也许可以解决问题,代码如下:

  1. package com.nf.math;
  2. public class ObjUtil {
  3. public static void main(String[] args) {
  4. Stack stack=new Stack();
  5. stack.push(1.1);
  6. stack.push(2.2);
  7. stack.push(5.5);
  8. double data=(double)stack.pop();
  9. System.out.println(data);
  10. System.out.println(stack.pop());
  11. System.out.println(stack.pop());
  12. }
  13. }
  14. class Stack{
  15. //用于存放数据的数组
  16. private Object[] data=new Object[10];
  17. //当前下标
  18. private int i=0;
  19. //进栈
  20. public void push(Object obj){
  21. data[i++]=obj;
  22. }
  23. //出栈
  24. public Object pop(){
  25. return data[--i];
  26. }
  27. }

结果:

  1. 5.5
  2. 2.2
  3. 1.1

缺点是安全隐患(类型转换)

版本二中存在类型的强制转换,如果转换的类型不匹配则会引起运行时异常,存在安全隐患,使用泛型可以解决该问题:

  1. package com.nf.math;
  2. public class ObjUtil {
  3. public static void main(String[] args) {
  4. Stack<Double> stack=new Stack<Double>();
  5. stack.push(1.1);
  6. stack.push(2.2);
  7. stack.push(5.5);
  8. double data=stack.pop(); //不需要拆箱,没有类型转换
  9. System.out.println(data);
  10. System.out.println(stack.pop());
  11. System.out.println(stack.pop());
  12. }
  13. }
  14. class Stack<T>{
  15. //用于存放数据的数组
  16. private T[] data=(T[])(new Object[10]);
  17. //当前下标
  18. private int i=0;
  19. //进栈
  20. public void push(T obj){
  21. data[i++]=obj;
  22. }
  23. //出栈
  24. public T pop(){
  25. return data[--i];
  26. }
  27. }

结果:

  1. 5.5
  2. 2.2
  3. 1.1

因为使用了泛型,兼具了版本一与版本二的优点,没有类型转换,没有安全隐患,可以适用多种不同的数据类型。

java不支持泛型数组,List或ArrayList具有泛型数组的功能

没有泛型的情况的下,通过对类型Object的引用来实现参数的“任意化”,“任意化”带来的缺点是要做显式的强制类型转换,而这种转换是要求开发者对实际参数类型可以预知的情况下进行的。对于强制类型转换错误的情况,编译器可能不提示错误,在运行的时候才出现异常,这是一个安全隐患。

泛型的好处是在编译的时候检查类型安全,并且所有的强制转换都是自动和隐式的,以提高代码的重用率。

1、提高程序的安全性和可靠性
使用类型更安全,指定具体类型后,Java编译器会对错误的类型在编译时被捕获,而不是在运行时当作ClassCastException展示出来,从而提高程序的安全性和可靠性

2、消除强制类型转换
例如在集合里使用泛型后,从集合里取出对象后就不需要再进行强制类型转换了,这样使编写程序变得更简单,更不容易出错

3、提高代码重用率
在一个类里要对不同结构类型的对象进行操作时,有的对象成员和方法的逻辑都是一样的,就是类型不一样,就有可能会造成不必要的代码重复,通过使用泛型,只需要一个Java类就可以表示不同类型的对象,从而可以大大提高代码的重用率

1、泛型的类型参数只能是类类型(包括自定义类),不能是简单类型。

  1. Stack<Double> stack=new Stack<Double>();

2、同一种泛型可以对应多个版本(因为参数类型是不确定的),不同版本的泛型类实例是不兼容的

  1. Stack<Integer> stack2=stack; //错误

3、泛型的类型参数可以有多个。

  1. class Stack<T,E,K,M,X>{
  2. }

4、泛型的参数类型可以使用extends语句,例如<T extends superclass>。习惯上称为“有界类型”。

泛型约束,约束T的类型只能是superclass的子类型

5、泛型的参数类型还可以是通配符类型。例如Class<?> classType = Class.forName(“java.lang.String”);

java中方法参数传递的都是值,与C#区别很大,没有ref与out。

java中数据类型分为基本数据类型和引用数据类型。

  • 基本数据类型 
    • 整型:byte,short,int,long
    • 浮点型:float,double
    • 字符型:char
    • 布尔型:boolean
  • 引用数据类型 
    • 数组
    • 接口

方法的参数分为实际参数,和形式参数。

  • 形式参数:定义方法时写的参数。
  • 实际参数:调用方法时写的具体数值。
  1. package com.nf.math;
  2. public class ObjUtil {
  3. public static void main(String[] args) {
  4. Util util=new Util();
  5. int n1=100,n2=200;
  6. util.Swap(n1, n2); //副本
  7. System.out.println("n1="+n1+",n2="+n2);
  8. }
  9. }
  10. class Util
  11. {
  12. public void Swap(int n1, int n2) {
  13. int temp = n1;
  14. n1 = n2;
  15. n2 = temp;
  16. }
  17. }

结果:

  1. n1=100,n2=200

从上面的结果可以看出n1与n2在调用交换方法后并没有实质交换,是因为形参是n1与n2的副本。

  1. package com.nf.math;
  2. public class ObjUtil {
  3. public static void main(String[] args) {
  4. Util util=new Util();
  5. String n1="100",n2="200";
  6. util.Swap(n1, n2); //形参是n1的引用副本
  7. System.out.println("n1="+n1+",n2="+n2);
  8. }
  9. }
  10. class Util
  11. {
  12. public void Swap(String n1, String n2) {
  13. String temp = n1;
  14. n1 = n2;
  15. n2 = temp;
  16. }
  17. }

结果:

  1. n1=100,n2=200

依然没有交互

String对象做为参数传递时,走的依然是引用传递,只不过String这个类比较特殊。

String对象一旦创建,内容不可更改。每一次内容的更改都是重现创建出来的新对象。

  • 值传递的时候,将实参的,copy一份给形参。
  • 引用传递的时候,将实参的地址值,copy一份给形参。

也就是说,不管是值传递还是引用传递,形参拿到的仅仅是实参的副本,而不是实参本身。

 示例:

  1. package com.nf.math;
  2. public class BoxTest {
  3. public static void main(String[] args) {
  4. Box<Integer> boxInt = new Box<Integer>();
  5. boxInt.setAttr(5);
  6. System.out.println(boxInt.getAttr() + 1);
  7. }
  8. }
  9. class Box<T> {
  10. private T attr;
  11. public T getAttr() {
  12. return this.attr;
  13. }
  14. public void setAttr(T attr) {
  15. this.attr = attr;
  16. }
  17. }

结果:

6

在自定义泛型类中,整个类都可以使用类型占位T,有时候只需要局部用到则可以定义泛型方法

定义泛型方法,语法如下:

  1. [访问修饰符] <泛型列表> 返回值 方法名(参数列表) {
  2. //方法体;
  3. }

示例:

  1. package com.nf.math;
  2. import java.lang.reflect.Method;
  3. import java.lang.reflect.Modifier;
  4. public class BoxTest {
  5. public static void main(String[] args) {
  6. Box<Integer> boxInt = new Box<Integer>();
  7. boxInt.setAttr(5);
  8. System.out.println(boxInt.getAttr() + 1);
  9. ReflectUtil.getMethods(Box.class);
  10. }
  11. }
  12. class Box<T> {
  13. private T attr;
  14. public T getAttr() {
  15. return this.attr;
  16. }
  17. public void setAttr(T attr) {
  18. this.attr = attr;
  19. }
  20. }
  21. class ReflectUtil
  22. {
  23. public static <T> void getMethods(Class<T> type){
  24. Method[] methods=type.getMethods();
  25. System.out.println(type.getName()+":");
  26. for (Method method : methods) {
  27. System.out.println(Modifier.toString(method.getModifiers())+" "+method.getReturnType()+" "+method.getName()+"()");
  28. }
  29. }
  30. }

结果:

说明:

1)在泛型列表中声明的泛型,可用于该方法的返回值类型声明、参数类型声明和方法代码中的局部变量的类型声明

2)类中其他方法不能使用当前方法声明的泛型

3)使用泛型方法时,不必指明参数类型,编译器会自己找出具体的类型;泛型方法除了定义不同,调用就像普通方法一样。

注意:是否拥有泛型方法,与其所在的类是否泛型没有关系。要定义泛型方法,只需将泛型参数列表置于返回值前。

类型通配符一般是使用 ? 代替具体的类型实参。

  1. package com.nf.math;
  2. public class BeanTest {
  3. public static void main(String[] args) {
  4. // 同一种泛型可以对应多个版本(因为参数类型是不确定的)
  5. // 不同版本的泛型类实例是不兼容的。
  6. Bean<String> bean1 = new Bean<String>();
  7. Bean<Integer> bean2 = new Bean<Integer>();
  8. System.out.println(bean1.getClass().getName()); // 类型
  9. System.out.println(bean2.getClass().getName());
  10. Bean<Number> bean3 = bean1;
  11. }
  12. }
  13. class Bean<T> {
  14. private T var;
  15. public T getVar() {
  16. return var;
  17. }
  18. public void setVar(T var) {
  19. this.var = var;
  20. }
  21. @Override
  22. public String toString() {
  23. return var.toString();
  24. }
  25. }

运行结果:

示例

  1. package com.nf.math;
  2. public class BeanTest {
  3. public static void main(String[] args) {
  4. // 同一种泛型可以对应多个版本(因为参数类型是不确定的)
  5. // 不同版本的泛型类实例是不兼容的。
  6. Bean<String> bean1 = new Bean<String>();
  7. bean1.setVar("one");
  8. Bean<Integer> bean2 = new Bean<Integer>();
  9. bean2.setVar(2);
  10. System.out.println(bean1.getClass().getName()); // 类型
  11. System.out.println(bean2.getClass().getName());
  12. Bean<?> bean3 = bean1;
  13. Show(bean1);
  14. //Show(bean2);错误
  15. Display(bean1);
  16. Display(bean2);
  17. }
  18. public static void Show(Bean<String> p){
  19. System.out.println("内容是:"+p.getVar());
  20. }
  21. public static void Display(Bean<?> p){
  22. System.out.println("内容是:"+p);
  23. }
  24. }
  25. class Bean<T> {
  26. private T var;
  27. public T getVar() {
  28. return var;
  29. }
  30. public void setVar(T var) {
  31. this.var = var;
  32. }
  33. @Override
  34. public String toString() {
  35. return var.toString();
  36. }
  37. }

结果:

  1. com.nf.math.Bean
  2. com.nf.math.Bean
  3. 内容是:one
  4. 内容是:one
  5. 内容是:2

 示例: 

  1. class Info<T>{
  2. private T var ; // 定义泛型变量
  3. public void setVar(T var){
  4. this.var = var ;
  5. }
  6. public T getVar(){
  7. return this.var ;
  8. }
  9. public String toString(){ // 直接打印
  10. return this.var.toString() ;
  11. }
  12. };
  13. public class GenericsDemo{
  14. public static void main(String args[]){
  15. Info<String> i = new Info<String>() ; // 使用String为泛型类型
  16. i.setVar("it") ; // 设置内容
  17. fun(i) ;
  18. }
  19. public static void fun(Info<?> temp){ // 可以接收任意的泛型对象
  20. System.out.println("内容:" + temp) ;
  21. }
  22. };

类型通配符上限通过形如Stack<? extends Number>形式定义

  1. class Info<T>{
  2. private T var ; // 定义泛型变量
  3. public void setVar(T var){
  4. this.var = var ;
  5. }
  6. public T getVar(){
  7. return this.var ;
  8. }
  9. public String toString(){ // 直接打印
  10. return this.var.toString() ;
  11. }
  12. };
  13. public class GenericsDemo17{
  14. public static void main(String args[]){
  15. Info<Integer> i1 = new Info<Integer>() ; // 声明Integer的泛型对象
  16. Info<Float> i2 = new Info<Float>() ; // 声明Float的泛型对象
  17. i1.setVar(30) ; // 设置整数,自动装箱
  18. i2.setVar(30.1f) ; // 设置小数,自动装箱
  19. fun(i1) ;
  20. fun(i2) ;
  21. }
  22. public static void fun(Info<? extends Number> temp){ // 只能接收Number及其Number的子类
  23. System.out.print(temp + "、") ;
  24. }
  25. };

 示例

  1. package com.nf.math;
  2. public class BeanTest {
  3. public static void main(String[] args) {
  4. Bean<String> bean1 = new Bean<String>();
  5. bean1.setVar("one");
  6. //public final class Integer extends Number implements Comparable<Integer> {
  7. Bean<Integer> bean2 = new Bean<Integer>();
  8. bean2.setVar(2);
  9. Bean<Number> bean3 = new Bean<Number>();
  10. bean3.setVar(3);
  11. //Display(bean1); 错误,原因是T必须继承Number或就是Number类型
  12. Display(bean2);
  13. Display(bean3);
  14. }
  15. public static void Display(Bean<? extends Number> p){
  16. System.out.println("内容是:"+p);
  17. }
  18. }
  19. class Bean<T> {
  20. private T var;
  21. public T getVar() {
  22. return var;
  23. }
  24. public void setVar(T var) {
  25. this.var = var;
  26. }
  27. @Override
  28. public String toString() {
  29. return var.toString();
  30. }
  31. }

结果

  1. 内容是:2
  2. 内容是:3
  1. package com.nf.math;
  2. public class BeanTest {
  3. public static void main(String[] args) {
  4. Bean<String> bean1 = new Bean<String>(); //错误,因为T有上界,要求是Number或Number的子类
  5. //public final class Integer extends Number implements Comparable<Integer>
  6. Bean<Integer> bean2 = new Bean<Integer>();
  7. Bean<Number> bean3 = new Bean<Number>();
  8. }
  9. }
  10. class Bean<T extends Number> { //T必须继承Number或就是Number
  11. private T var;
  12. public T getVar() {
  13. return var;
  14. }
  15. public void setVar(T var) {
  16. this.var = var;
  17. }
  18. @Override
  19. public String toString() {
  20. return var.toString();
  21. }
  22. }
  1. class CT extends Comparable<? super T & Serializable

我们来分析以下这句,T extends Comparable这个是对上限的限制,Comparable< super T>这个是下限的限制,Serializable是第2个上限。一个指定的类型参数可以具有一个或多个上限。具有多重限制的类型参数可以用于访问它的每个限制的方法和域。 

  1. class Bean<T extends Number & Serializable>

类型通配符下限为Stack<? super Number>形式,其含义与类型通配符上限正好相反

  1. class Info<T>{
  2. private T var ; // 定义泛型变量
  3. public void setVar(T var){
  4. this.var = var ;
  5. }
  6. public T getVar(){
  7. return this.var ;
  8. }
  9. public String toString(){ // 直接打印
  10. return this.var.toString() ;
  11. }
  12. };
  13. public class GenericsDemo21{
  14. public static void main(String args[]){
  15. Info<String> i1 = new Info<String>() ; // 声明String的泛型对象
  16. Info<Object> i2 = new Info<Object>() ; // 声明Object的泛型对象
  17. i1.setVar("hello") ;
  18. i2.setVar(new Object()) ;
  19. fun(i1) ;
  20. fun(i2) ;
  21. }
  22. public static void fun(Info<? super String> temp){ // 只能接收String或Object类型的泛型
  23. System.out.print(temp + "、") ;
  24. }
  25. };

 示例:

  1. package com.nf.math;
  2. import java.io.Serializable;
  3. public class BeanTest {
  4. public static void main(String[] args) {
  5. Bean<String> bean1 = new Bean<String>();
  6. bean1.setVar("one");
  7. //public abstract class Number implements java.io.Serializable
  8. Bean<Integer> bean2 = new Bean<Integer>();
  9. bean2.setVar(2);
  10. Bean<Number> bean3 = new Bean<Number>();
  11. bean3.setVar(3);
  12. Bean<Object> bean4 = new Bean<Object>();
  13. bean4.setVar(4);
  14. Bean<Serializable> bean5 = new Bean<Serializable>();
  15. bean5.setVar("5");
  16. //Display(bean1); //错误
  17. //Display(bean2); //错误
  18. Display(bean3);
  19. Display(bean4);
  20. Display(bean5);
  21. }
  22. //?必是Number或Number的父类,Object,Serializable,Number
  23. public static void Display(Bean<? super Number> p){
  24. System.out.println("内容是:"+p);
  25. }
  26. }
  27. class Bean<T> {
  28. private T var;
  29. public T getVar() {
  30. return var;
  31. }
  32. public void setVar(T var) {
  33. this.var = var;
  34. }
  35. @Override
  36. public String toString() {
  37. return var.toString();
  38. }
  39. }

结果:

  1. 内容是:3
  2. 内容是:4
  3. 内容是:5

没有,不存在…

Java中的泛型基本上都是在编译器这个层次来实现的。在生成的Java字节代码中是不包含泛型中的类型信息的。使用泛型的时候加上的类型参数,会被编译器在编译的时候去掉。这个过程就称为类型擦除。如在代码中定义的List<Object>和List<String>等类型,在编译之后都会变成List。JVM看到的只是List,而由泛型附加的类型信息对JVM来说是不可见的。Java编译器会在编译时尽可能的发现可能出错的地方,但是仍然无法避免在运行时刻出现类型转换异常的情况。类型擦除也是Java的泛型实现方式与C++模板机制实现方式之间的重要区别。

Java 的泛型在编译器有效,在运行期被删除,也就是说所有泛型参数类型在编译后都会被清除掉。

Java在泛型设计上是一种“伪泛型”,存在着泛型擦除。

类型擦除是Java中泛型的实现方式。泛型是在编译器这个层次来实现的。在Java 源代码中声明的泛型类型信息,在编译过程中会被擦除,只保留不带类型参数的形式。被擦除的类型信息包括泛型类型和泛型方法声明时的形式类型参数,以及参数化类型中的实际类型信息。经过类型擦除之后,包含泛型类型的代码被转换成不包含泛型类型的代码,相当于回到了泛型被引入之前的形式,Java虚拟机在运行字节代码时并不知道泛型类型的存在。 

定义好的泛型类:

  1. public class ObjectHolder<T> {
  2. private T obj;
  3. public T getObject() {
  4. return obj;
  5. }
  6. public void setObject(T obj) {
  7. this.obj = obj;
  8. }
  9. }

被转译后:

以上面代码中的ObjectHolder泛型类为例,经过类型擦除后,由于形式类型参数T没有上界,T的所有出现将被替换成Object类型

  1. public class ObjectHolder {
  2. private Object obj;
  3. public Object getObject() {
  4. return obj;
  5. }
  6. public void setObject(Object obj) {
  7. this.obj = obj;
  8. }
  9. }

另外使用ObjectHolder类的代码也要进行处理,如下列代码所示:

  1. ObjectHolder<String> holder = new ObjectHolder<String>();
  2. holder.setObject("Hello");
  3. String str = holder.getObject();

在类型擦除后,ObjectHolder类中的getObject方法的返冋值类型实际上是 Object类型,因此需要添加强制类型转换把getObject方法的返回值转换成String类型。 这些类型转换操作由编译器自动添加。由于编译器已经确保不允许使用除String类的对象之外的其他对象调用setObject方法,因此这个强制类型转换操作始终是合法的,如下列代码所示:

  1. ObjectHolder holder = new ObjectHolder();
  2. holder.setObject("Hello");
  3. String str = (String)holder.getObject();

泛型信息只存在于代码编译阶段,在进入 JVM 之前,与泛型相关的信息会被擦除掉,专业术语叫做类型擦除

示例:

  1. package com.nf.math;
  2. public class BeanTest {
  3. public static void main(String[] args) {
  4. Bean<Integer> bean1=new Bean<Integer>();
  5. Bean<String> bean2=new Bean<String>();
  6. System.out.println(bean1.getClass().getName());
  7. System.out.println(bean2.getClass().getName());
  8. }
  9. }
  10. class Bean<T> {
  11. private T var;
  12. public T getVar() {
  13. return var;
  14. }
  15. public void setVar(T var) {
  16. this.var = var;
  17. }
  18. @Override
  19. public String toString() {
  20. return var.toString();
  21. }
  22. }

结果:

  1. com.nf.math.Bean
  2. com.nf.math.Bean 

 在JVM中的 Class 都是com.nf.math.Bean,泛型信息被擦除了。

示例:

  1. package com.nf.math;
  2. import java.lang.reflect.Field;
  3. public class BeanTest {
  4. public static void main(String[] args) throws Exception {
  5. Bean<Integer> bean1=new Bean<Integer>();
  6. Bean<String> bean2=new Bean<String>();
  7. //获得Bean中的字段var
  8. Field clazz=bean1.getClass().getDeclaredField("var");
  9. clazz.setAccessible(true);
  10. clazz.set(bean1, "abc");
  11. //取字段var的类型
  12. System.out.println(clazz.getType().getSimpleName());
  13. System.out.println(bean1.getVar());
  14. }
  15. }
  16. class Bean<T> {
  17. private T var;
  18. public T getVar() {
  19. return var;
  20. }
  21. public void setVar(T var) {
  22. this.var = var;
  23. }
  24. @Override
  25. public String toString() {
  26. return var.toString();
  27. }
  28. }

 因为Bean没有上界,T被转译成Object,生成如下代码:

  1. class BeanCopy {
  2. private Object var;
  3. public Object getVar() {
  4. return var;
  5. }
  6. public void setVar(Object var) {
  7. this.var = var;
  8. }
  9. @Override
  10. public String toString() {
  11. return var.toString();
  12. }
  13. } 

运行结果:

  1. Object
  2. abc

泛型类被类型擦除后,相应的类型就被替换成 Object 类型呢?,不一定,如果有上界,则被替换成上界:

  1. package com.nf.math;
  2. import java.lang.reflect.Field;
  3. public class BeanTest {
  4. public static void main(String[] args) throws Exception {
  5. Bean<Integer> bean1=new Bean<Integer>();
  6. Bean<Number> bean2=new Bean<Number>();
  7. //获得Bean中的字段var
  8. Field clazz=bean1.getClass().getDeclaredField("var");
  9. //查看运行时字段var的类型
  10. System.out.println(clazz.getType().getSimpleName());
  11. }
  12. }
  13. class Bean<T extends Number> { //设置上界
  14. private T var;
  15. public T getVar() {
  16. return var;
  17. }
  18. public void setVar(T var) {
  19. this.var = var;
  20. }
  21. @Override
  22. public String toString() {
  23. return var.toString();
  24. }
  25. }

运行结果:

  1. Number

类型被转译成:

  1. class Bean{
  2. private Number var;
  3. public Number getVar() {
  4. return var;
  5. }
  6. public void setVar(Number var) {
  7. this.var = var;
  8. }
  9. @Override
  10. public String toString() {
  11. return var.toString();
  12. }
  13. }

参考:https://commons.apache.org/proper/commons-dbutils/

已经写好的工具类:

  1. package com.zhangguo.utils;
  2. import java.lang.reflect.InvocationTargetException;
  3. import java.lang.reflect.Method;
  4. import java.sql.Connection;
  5. import java.sql.DriverManager;
  6. import java.sql.PreparedStatement;
  7. import java.sql.ResultSet;
  8. import java.sql.ResultSetMetaData;
  9. import java.sql.SQLException;
  10. import java.sql.Statement;
  11. import java.util.ArrayList;
  12. import java.util.HashMap;
  13. import java.util.List;
  14. import java.util.Map;
  15. public class JDBCUtils {
  16. public static String DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
  17. public static String URL = "jdbc:sqlserver://localhost:1433;databasename=pubs";
  18. public static String USER_NAME = "sa";
  19. public static String PASSWORD = "sa";
  20. static {
  21. try {
  22. Class.forName(DRIVER);
  23. } catch (ClassNotFoundException e) {
  24. e.printStackTrace();
  25. }
  26. }
  27. private JDBCUtils() {
  28. }
  29. /**
  30. * Get connection
  31. *
  32. * @return
  33. */
  34. public static Connection getconnnection() {
  35. Connection con = null;
  36. try {
  37. con = DriverManager.getConnection(URL, USER_NAME, PASSWORD);
  38. } catch (SQLException e) {
  39. e.printStackTrace();
  40. }
  41. return con;
  42. }
  43. /**
  44. * Close connection
  45. *
  46. * @param rs
  47. * @param st
  48. * @param con
  49. */
  50. public static void close(ResultSet rs, Statement st, Connection con) {
  51. try {
  52. try {
  53. if (rs != null) {
  54. rs.close();
  55. }
  56. } finally {
  57. try {
  58. if (st != null) {
  59. st.close();
  60. }
  61. } finally {
  62. if (con != null)
  63. con.close();
  64. }
  65. }
  66. } catch (SQLException e) {
  67. e.printStackTrace();
  68. }
  69. }
  70. /**
  71. * Close connection
  72. *
  73. * @param rs
  74. */
  75. public static void close(ResultSet rs) {
  76. Statement st = null;
  77. Connection con = null;
  78. try {
  79. try {
  80. if (rs != null) {
  81. st = rs.getStatement();
  82. rs.close();
  83. }
  84. } finally {
  85. try {
  86. if (st != null) {
  87. con = st.getConnection();
  88. st.close();
  89. }
  90. } finally {
  91. if (con != null) {
  92. con.close();
  93. }
  94. }
  95. }
  96. } catch (SQLException e) {
  97. e.printStackTrace();
  98. }
  99. }
  100. /**
  101. * Close connection
  102. *
  103. * @param st
  104. * @param con
  105. */
  106. public static void close(Statement st, Connection con) {
  107. try {
  108. try {
  109. if (st != null) {
  110. st.close();
  111. }
  112. } finally {
  113. if (con != null)
  114. con.close();
  115. }
  116. } catch (SQLException e) {
  117. e.printStackTrace();
  118. }
  119. }
  120. /**
  121. * insert/update/delete
  122. *
  123. * @param sql
  124. * @param args
  125. * @return
  126. */
  127. public static int update(String sql, Object... args) {
  128. int result = 0;
  129. Connection con = getconnnection();
  130. PreparedStatement ps = null;
  131. try {
  132. ps = con.prepareStatement(sql);
  133. if (args != null) {
  134. for (int i = 0; i < args.length; i++) {
  135. ps.setObject((i + 1), args[i]);
  136. }
  137. }
  138. result = ps.executeUpdate();
  139. } catch (SQLException e) {
  140. e.printStackTrace();
  141. } finally {
  142. close(ps, con);
  143. }
  144. return result;
  145. }
  146. /**
  147. * query, because need to manually close the resource, so not recommended
  148. * for use it
  149. *
  150. * @param sql
  151. * @param args
  152. * @return ResultSet
  153. */
  154. @Deprecated
  155. public static ResultSet query(String sql, Object... args) {
  156. ResultSet result = null;
  157. Connection con = getconnnection();
  158. PreparedStatement ps = null;
  159. try {
  160. ps = con.prepareStatement(sql);
  161. if (args != null) {
  162. for (int i = 0; i < args.length; i++) {
  163. ps.setObject((i + 1), args[i]);
  164. }
  165. }
  166. result = ps.executeQuery();
  167. } catch (SQLException e) {
  168. e.printStackTrace();
  169. }
  170. return result;
  171. }
  172. /**
  173. * Query a single record
  174. *
  175. * @param sql
  176. * @param args
  177. * @return Map<String,Object>
  178. */
  179. public static Map<String, Object> queryForMap(String sql, Object... args) {
  180. Map<String, Object> result = new HashMap<String, Object>();
  181. List<Map<String, Object>> list = queryForList(sql, args);
  182. if (list.size() > 0) {
  183. result = list.get(0);
  184. }
  185. return result;
  186. }
  187. /**
  188. * Query a single record
  189. *
  190. * @param sql
  191. * @param args
  192. * @return <T>
  193. */
  194. public static <T> T queryForObject(String sql, Class<T> clz, Object... args) {
  195. T result = null;
  196. List<T> list = queryForList(sql, clz, args);
  197. if (list.size() > 0) {
  198. result = list.get(0);
  199. }
  200. return result;
  201. }
  202. /**
  203. * Query a single record
  204. *
  205. * @param sql
  206. * @param args
  207. * @return List<Map<String,Object>>
  208. */
  209. public static List<Map<String, Object>> queryForList(String sql, Object... args) {
  210. List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
  211. Connection con = null;
  212. ResultSet rs = null;
  213. PreparedStatement ps = null;
  214. try {
  215. con = getconnnection();
  216. ps = con.prepareStatement(sql);
  217. if (args != null) {
  218. for (int i = 0; i < args.length; i++) {
  219. ps.setObject((i + 1), args[i]);
  220. }
  221. }
  222. rs = ps.executeQuery();
  223. ResultSetMetaData rsmd = rs.getMetaData();
  224. int columnCount = rsmd.getColumnCount();
  225. while (rs.next()) {
  226. Map<String, Object> map = new HashMap<String, Object>();
  227. for (int i = 1; i <= columnCount; i++) {
  228. map.put(rsmd.getColumnLabel(i), rs.getObject(i));
  229. }
  230. result.add(map);
  231. }
  232. } catch (SQLException e) {
  233. e.printStackTrace();
  234. } finally {
  235. close(rs, ps, con);
  236. }
  237. return result;
  238. }
  239. /**
  240. * Query a single record
  241. *
  242. * @param sql
  243. * @param args
  244. * @return List<T>
  245. */
  246. public static <T> List<T> queryForList(String sql, Class<T> clz, Object... args) {
  247. List<T> result = new ArrayList<T>();
  248. Connection con = null;
  249. PreparedStatement ps = null;
  250. ResultSet rs = null;
  251. try {
  252. con = getconnnection();
  253. ps = con.prepareStatement(sql);
  254. if (args != null) {
  255. for (int i = 0; i < args.length; i++) {
  256. ps.setObject((i + 1), args[i]);
  257. }
  258. }
  259. rs = ps.executeQuery();
  260. ResultSetMetaData rsmd = rs.getMetaData();
  261. int columnCount = rsmd.getColumnCount();
  262. while (rs.next()) {
  263. T obj = clz.newInstance();
  264. for (int i = 1; i <= columnCount; i++) {
  265. String columnName = rsmd.getColumnName(i);
  266. String methodName = "set" + columnName.substring(0, 1).toUpperCase()
  267. + columnName.substring(1, columnName.length());
  268. Method method[] = clz.getMethods();
  269. for (Method meth : method) {
  270. if (methodName.equals(meth.getName())) {
  271. meth.invoke(obj, rs.getObject(i));
  272. }
  273. }
  274. }
  275. result.add(obj);
  276. }
  277. } catch (InstantiationException e) {
  278. e.printStackTrace();
  279. } catch (IllegalAccessException e) {
  280. e.printStackTrace();
  281. } catch (SQLException e) {
  282. e.printStackTrace();
  283. } catch (IllegalArgumentException e) {
  284. e.printStackTrace();
  285. } catch (InvocationTargetException e) {
  286. e.printStackTrace();
  287. } finally {
  288. close(rs, ps, con);
  289. }
  290. return result;
  291. }
  292. }

View Code

数据库:

  1. CREATE TABLE `student` (
  2. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '编号',
  3. `name` varchar(50) DEFAULT NULL COMMENT '姓名',
  4. `sex` varchar(20) DEFAULT NULL,
  5. `cno` varchar(50) DEFAULT NULL COMMENT '班级',
  6. `addr` varchar(50) DEFAULT NULL COMMENT '籍贯',
  7. PRIMARY KEY (`id`)
  8. ) ENGINE=InnoDB AUTO_INCREMENT=13 DEFAULT CHARSET=utf8;

示例:

  1. package com.zhangguo.utils;
  2. import java.util.List;
  3. public class JDBCUtilsTest {
  4. public static void main(String[] args) {
  5. List<Student> students = JDBCUtils.queryForList("select * from student where id<=?", Student.class, 10);
  6. for (Student student : students) {
  7. System.out.println(student);
  8. }
  9. }
  10. }
  11. /** 学生 */
  12. class Student {
  13. private int id;
  14. private String name;
  15. private String sex;
  16. private String cno;
  17. private String addr;
  18. public int getId() {
  19. return id;
  20. }
  21. public void setId(int id) {
  22. this.id = id;
  23. }
  24. public String getName() {
  25. return name;
  26. }
  27. public void setName(String name) {
  28. this.name = name;
  29. }
  30. public String getSex() {
  31. return sex;
  32. }
  33. public void setSex(String sex) {
  34. this.sex = sex;
  35. }
  36. public String getCno() {
  37. return cno;
  38. }
  39. public void setCno(String cno) {
  40. this.cno = cno;
  41. }
  42. public String getAddr() {
  43. return addr;
  44. }
  45. public void setAddr(String addr) {
  46. this.addr = addr;
  47. }
  48. @Override
  49. public String toString() {
  50. return "Student [id=" + id + ", name=" + name + ", sex=" + sex + ", cno=" + cno + ", addr=" + addr + "]";
  51. }
  52. }

结果:

数据库与表的元数据就是用于描述数据库或表的信息,如表的字段(长度,类型,注释),主键,外键,约束等信息,表中的数据本来是描述客观事物的。

示例:

  1. /**
  2. * 根据数据库的连接参数,获取指定表的基本信息:字段名、字段类型、字段注释
  3. * 表名
  4. * @return Map集合
  5. */
  6. public static List getTableInfo(String table) {
  7. List result = new ArrayList();
  8. Connection conn = null;
  9. DatabaseMetaData dbmd = null;
  10. try {
  11. conn = DriverManager.getConnection(URL, USER_NAME, PASSWORD);
  12. dbmd = conn.getMetaData();
  13. ResultSet resultSet = dbmd.getTables(null, "%", table, new String[] { "TABLE" });
  14. while (resultSet.next()) {
  15. String tableName = resultSet.getString("TABLE_NAME");
  16. System.out.println(tableName);
  17. if (tableName.equals(table)) {
  18. ResultSet rs = conn.getMetaData().getColumns(null, getSchema(conn), tableName.toUpperCase(), "%");
  19. while (rs.next()) {
  20. // System.out.println("字段名:"+rs.getString("COLUMN_NAME")+"--字段注释:"+rs.getString("REMARKS")+"--字段数据类型:"+rs.getString("TYPE_NAME"));
  21. Map map = new HashMap();
  22. String colName = rs.getString("COLUMN_NAME");
  23. map.put("code", colName);
  24. String remarks = rs.getString("REMARKS");
  25. if (remarks == null || remarks.equals("")) {
  26. remarks = colName;
  27. }
  28. map.put("name", remarks);
  29. String dbType = rs.getString("TYPE_NAME");
  30. map.put("dbType", dbType);
  31. map.put("valueType", changeDbType(dbType));
  32. result.add(map);
  33. }
  34. }
  35. }
  36. } catch (SQLException e) {
  37. e.printStackTrace();
  38. } catch (Exception e) {
  39. e.printStackTrace();
  40. } finally {
  41. try {
  42. conn.close();
  43. } catch (SQLException e) {
  44. e.printStackTrace();
  45. }
  46. }
  47. return result;
  48. }
  49. private static String changeDbType(String dbType) {
  50. dbType = dbType.toUpperCase();
  51. switch (dbType) {
  52. case "VARCHAR":
  53. case "VARCHAR2":
  54. case "CHAR":
  55. return "1";
  56. case "NUMBER":
  57. case "DECIMAL":
  58. return "4";
  59. case "INT":
  60. case "SMALLINT":
  61. case "INTEGER":
  62. return "2";
  63. case "BIGINT":
  64. return "6";
  65. case "DATETIME":
  66. case "TIMESTAMP":
  67. case "DATE":
  68. return "7";
  69. default:
  70. return "1";
  71. }
  72. }
  73. // 其他数据库不需要这个方法 oracle和db2需要
  74. private static String getSchema(Connection conn) throws Exception {
  75. String schema;
  76. schema = conn.getMetaData().getUserName();
  77. if ((schema == null) || (schema.length() == 0)) {
  78. throw new Exception("ORACLE数据库模式不允许为空");
  79. }
  80. return schema.toUpperCase().toString();
  81. }

结果:

  1. persons
  2. student
  3. [{code=id, valueType=2, name=编号, dbType=INT}, {code=name, valueType=1, name=姓名, dbType=VARCHAR}, {code=sex, valueType=1, name=sex, dbType=VARCHAR}, {code=cno, valueType=1, name=班级, dbType=VARCHAR}, {code=addr, valueType=1, name=籍贯, dbType=VARCHAR}]

View Code

代码:

  1. package com.zhangguo.utils;
  2. import java.sql.Connection;
  3. import java.sql.DriverManager;
  4. import java.sql.PreparedStatement;
  5. import java.sql.ResultSet;
  6. import java.sql.ResultSetMetaData;
  7. import java.sql.SQLException;
  8. import java.util.ArrayList;
  9. import java.util.List;
  10. public class DbUtils {
  11. public static String DRIVER = "com.mysql.jdbc.Driver";
  12. public static String URL = "jdbc:mysql://localhost:3306/studentmis?useUnicode=true&characterEncoding=utf8";
  13. public static String USER_NAME = "mysqluser";
  14. public static String PASSWORD = "root";
  15. static {
  16. try {
  17. Class.forName(DRIVER);
  18. } catch (ClassNotFoundException e) {
  19. e.printStackTrace();
  20. }
  21. }
  22. public static List<Student> getStudents(String sql, Object... params) throws Exception {
  23. List<Student> result = new ArrayList<>();
  24. Connection conn = null;
  25. PreparedStatement pstm = null;
  26. conn = DriverManager.getConnection(URL, USER_NAME, PASSWORD);
  27. pstm = conn.prepareStatement(sql);
  28. // 添加参数
  29. if (params != null) {
  30. for (int i = 0; i < params.length; i++) {
  31. pstm.setObject(i + 1, params[i]);
  32. }
  33. }
  34. // 执行查询
  35. ResultSet rs = pstm.executeQuery();
  36. //获得表的元数据
  37. ResultSetMetaData rsmd=pstm.getMetaData();
  38. //表的列数
  39. int metaSize=rsmd.getColumnCount();
  40. for (int i =1; i <=metaSize; i++) {
  41. System.out.println("列名:"+rsmd.getColumnName(i));
  42. System.out.println("长度:"+rsmd.getColumnDisplaySize(i));
  43. System.out.println("类型:"+rsmd.getColumnType(i));
  44. System.out.println("类型:"+rsmd.getColumnTypeName(i));
  45. System.out.println("----------");
  46. }
  47. while (rs.next()) {
  48. Student student=new Student();
  49. student.setAddr(rs.getString("addr"));
  50. student.setCno(rs.getString("cno"));
  51. student.setId(rs.getInt("id"));
  52. student.setName(rs.getString("name"));
  53. student.setSex(rs.getString("sex"));
  54. result.add(student);
  55. }
  56. CloseConnection(conn, pstm, rs);
  57. return result;
  58. }
  59. public static void CloseConnection(Connection conn, PreparedStatement pstm, ResultSet rs) throws SQLException {
  60. if (rs != null) {
  61. rs.close();
  62. }
  63. if (pstm != null) {
  64. pstm.close();
  65. }
  66. if (conn != null) {
  67. conn.close();
  68. }
  69. }
  70. }

测试类:

  1. package com.zhangguo.utils;
  2. import java.util.List;
  3. public class JDBCUtilsTest {
  4. public static void main(String[] args) throws Exception {
  5. List<Student> students = JDBCUtils.queryForList("select * from student where id<=?", Student.class, 10);
  6. for (Student student : students) {
  7. System.out.println(student);
  8. }
  9. System.out.println("-------------------------------------------------------------------");
  10. List<Student> stus =DbUtils.getStudents("select * from student where id<=?", 5);
  11. for (Student student : stus) {
  12. System.out.println(student);
  13. }
  14. System.out.println("-------------------------------------------------------------------");
  15. System.out.println(stus);
  16. }
  17. }
  18. /** 学生 */
  19. class Student {
  20. private int id;
  21. private String name;
  22. private String sex;
  23. private String cno;
  24. private String addr;
  25. public int getId() {
  26. return id;
  27. }
  28. public void setId(int id) {
  29. this.id = id;
  30. }
  31. public String getName() {
  32. return name;
  33. }
  34. public void setName(String name) {
  35. this.name = name;
  36. }
  37. public String getSex() {
  38. return sex;
  39. }
  40. public void setSex(String sex) {
  41. this.sex = sex;
  42. }
  43. public String getCno() {
  44. return cno;
  45. }
  46. public void setCno(String cno) {
  47. this.cno = cno;
  48. }
  49. public String getAddr() {
  50. return addr;
  51. }
  52. public void setAddr(String addr) {
  53. this.addr = addr;
  54. }
  55. @Override
  56. public String toString() {
  57. return "Student [id=" + id + ", name=" + name + ", sex=" + sex + ", cno=" + cno + ", addr=" + addr + "]";
  58. }
  59. }

结果:

  1. Student [id=1, name=张学友, sex=男, cno=S1SJ90, addr=中国香港]
  2. Student [id=2, name=黎明, sex=男, cno=S1SJ18, addr=中国上海]
  3. Student [id=3, name=张慧妹, sex=女, cno=S2SJ19, addr=中国北京]
  4. Student [id=4, name=张国立, sex=男, cno=S3J37, addr=中国广东]
  5. Student [id=5, name=张哪啦, sex=女, cno=S3SR96, addr=中国杭州]
  6. Student [id=6, name=张铁林, sex=男, cno=S2SJ140, addr=中国珠海]
  7. Student [id=7, name=张国荣, sex=男, cno=S1SJ111, addr=中国香港]
  8. Student [id=8, name=张果果, sex=女, cno=S3SU198, addr=中国深圳]
  9. Student [id=10, name=张小军, sex=女, cno=S1SN196, addr=中国斗门]
  10. -------------------------------------------------------------------
  11. 列名:id
  12. 长度:11
  13. 类型:4
  14. 类型:INT
  15. ----------
  16. 列名:name
  17. 长度:50
  18. 类型:12
  19. 类型:VARCHAR
  20. ----------
  21. 列名:sex
  22. 长度:20
  23. 类型:12
  24. 类型:VARCHAR
  25. ----------
  26. 列名:cno
  27. 长度:50
  28. 类型:12
  29. 类型:VARCHAR
  30. ----------
  31. 列名:addr
  32. 长度:50
  33. 类型:12
  34. 类型:VARCHAR
  35. ----------
  36. Student [id=1, name=张学友, sex=男, cno=S1SJ90, addr=中国香港]
  37. Student [id=2, name=黎明, sex=男, cno=S1SJ18, addr=中国上海]
  38. Student [id=3, name=张慧妹, sex=女, cno=S2SJ19, addr=中国北京]
  39. Student [id=4, name=张国立, sex=男, cno=S3J37, addr=中国广东]
  40. Student [id=5, name=张哪啦, sex=女, cno=S3SR96, addr=中国杭州]
  41. -------------------------------------------------------------------
  42. [Student [id=1, name=张学友, sex=男, cno=S1SJ90, addr=中国香港], Student [id=2, name=黎明, sex=男, cno=S1SJ18, addr=中国上海], Student [id=3, name=张慧妹, sex=女, cno=S2SJ19, addr=中国北京], Student [id=4, name=张国立, sex=男, cno=S3J37, addr=中国广东], Student [id=5, name=张哪啦, sex=女, cno=S3SR96, addr=中国杭州]]
  1. package com.zhangguo.utilities;
  2. import java.lang.reflect.Field;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.PreparedStatement;
  6. import java.sql.ResultSet;
  7. import java.sql.ResultSetMetaData;
  8. import java.sql.SQLException;
  9. import java.util.ArrayList;
  10. import java.util.List;
  11. public class DbUtils {
  12. public static String DRIVER = "com.mysql.jdbc.Driver";
  13. public static String URL = "jdbc:mysql://localhost:3306/studentmis?useUnicode=true&characterEncoding=utf8";
  14. public static String USER_NAME = "mysqluser";
  15. public static String PASSWORD = "root";
  16. static {
  17. try {
  18. Class.forName(DRIVER);
  19. } catch (ClassNotFoundException e) {
  20. e.printStackTrace();
  21. }
  22. }
  23. public static <T> List<T> queryList(String sql,Class<T> clazz,Object... params) throws Exception {
  24. List<T> result = new ArrayList<>();
  25. Connection conn = null;
  26. PreparedStatement pstm = null;
  27. conn = DriverManager.getConnection(URL, USER_NAME, PASSWORD);
  28. pstm = conn.prepareStatement(sql);
  29. // 添加参数
  30. if (params != null) {
  31. for (int i = 0; i < params.length; i++) {
  32. pstm.setObject(i + 1, params[i]);
  33. }
  34. }
  35. // 执行查询
  36. ResultSet rs = pstm.executeQuery();
  37. // 获得表的元数据
  38. ResultSetMetaData rsmd = pstm.getMetaData();
  39. // 表的列数
  40. int metaSize = rsmd.getColumnCount();
  41. while (rs.next()) {
  42. T entity = clazz.newInstance();
  43. for (int i = 1; i <= metaSize; i++) {
  44. //获得当前列的列名
  45. String columnName=rsmd.getColumnName(i);
  46. //根据字段名获得实体类中的字段
  47. Field field=clazz.getDeclaredField(columnName);
  48. //设置字段可以被访问
  49. field.setAccessible(true);
  50. //给实体中的字段赋值
  51. field.set(entity, rs.getObject(columnName));
  52. }
  53. result.add(entity);
  54. }
  55. CloseConnection(conn, pstm, rs);
  56. return result;
  57. }
  58. public static void CloseConnection(Connection conn, PreparedStatement pstm, ResultSet rs) throws SQLException {
  59. if (rs != null) {
  60. rs.close();
  61. }
  62. if (pstm != null) {
  63. pstm.close();
  64. }
  65. if (conn != null) {
  66. conn.close();
  67. }
  68. }
  69. }

测试:

  1. package com.zhangguo.utilities;
  2. import java.util.List;
  3. public class DbUtilsTest {
  4. public static void main(String[] args) throws Exception {
  5. List<Animal> result = DbUtils.queryList("select * from animal where id<?", Animal.class, 5);
  6. System.out.println(result);
  7. List<Student> students = DbUtils.queryList("select * from student where id<?", Student.class, 5);
  8. System.out.println(students);
  9. }
  10. }
  11. /** 动物 */
  12. class Animal {
  13. private int id;
  14. private String name;
  15. private String color;
  16. public int getId() {
  17. return id;
  18. }
  19. public void setId(int id) {
  20. this.id = id;
  21. }
  22. public String getName() {
  23. return name;
  24. }
  25. public void setName(String name) {
  26. this.name = name;
  27. }
  28. public String getColor() {
  29. return color;
  30. }
  31. public void setColor(String color) {
  32. this.color = color;
  33. }
  34. @Override
  35. public String toString() {
  36. return "Animal [id=" + id + ", name=" + name + ", color=" + color + "]";
  37. }
  38. }
  39. /** 学生 */
  40. class Student { //T只允许是String或String的子类
  41. private int id;
  42. private String name;
  43. private String sex;
  44. private String cno;
  45. private String addr;
  46. public int getId() {
  47. return id;
  48. }
  49. public void setId(int id) {
  50. this.id = id;
  51. }
  52. public String getName() {
  53. return name;
  54. }
  55. public void setName(String name) {
  56. this.name = name;
  57. }
  58. public String getSex() {
  59. return sex;
  60. }
  61. public void setSex(String sex) {
  62. this.sex = sex;
  63. }
  64. public String getCno() {
  65. return cno;
  66. }
  67. public void setCno(String cno) {
  68. this.cno = cno;
  69. }
  70. public String getAddr() {
  71. return addr;
  72. }
  73. public void setAddr(String addr) {
  74. this.addr = addr;
  75. }
  76. @Override
  77. public String toString() {
  78. return "Student [id=" + id + ", name=" + name + ", sex=" + sex + ", cno=" + cno + ", addr=" + addr + "]";
  79. }
  80. }

结果:

  1. [Animal [id=1, name=Dog, color=yellow], Animal [id=2, name=Cat, color=White], Animal [id=3, name=Duck, color=Black]]
  2. [Student [id=1, name=张学友, sex=男, cno=S1SJ90, addr=中国香港], Student [id=2, name=黎明, sex=男, cno=S1SJ18, addr=中国上海], Student [id=3, name=张慧妹, sex=女, cno=S2SJ19, addr=中国北京], Student [id=4, name=张国立, sex=男, cno=S3J37, addr=中国广东]]

View Code

  1. package com.zhangguo.utilities;
  2. import java.lang.reflect.Field;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.PreparedStatement;
  6. import java.sql.ResultSet;
  7. import java.sql.ResultSetMetaData;
  8. import java.sql.SQLException;
  9. import java.util.ArrayList;
  10. import java.util.List;
  11. public class DbUtils {
  12. public static String DRIVER = "com.mysql.jdbc.Driver";
  13. public static String URL = "jdbc:mysql://localhost:3306/studentmis?useUnicode=true&characterEncoding=utf8";
  14. public static String USER_NAME = "mysqluser";
  15. public static String PASSWORD = "root";
  16. static {
  17. try {
  18. Class.forName(DRIVER);
  19. } catch (ClassNotFoundException e) {
  20. e.printStackTrace();
  21. }
  22. }
  23. public static <T> List<T> queryList(String sql, Class<T> clazz, Object... params) throws Exception {
  24. List<T> result = new ArrayList<>();
  25. Connection conn = null;
  26. PreparedStatement pstm = null;
  27. conn = DriverManager.getConnection(URL, USER_NAME, PASSWORD);
  28. pstm = conn.prepareStatement(sql);
  29. // 添加参数
  30. if (params != null) {
  31. for (int i = 0; i < params.length; i++) {
  32. pstm.setObject(i + 1, params[i]);
  33. }
  34. }
  35. // 执行查询
  36. ResultSet rs = pstm.executeQuery();
  37. // 获得表的元数据
  38. ResultSetMetaData rsmd = pstm.getMetaData();
  39. // 表的列数
  40. int metaSize = rsmd.getColumnCount();
  41. while (rs.next()) {
  42. T entity = clazz.newInstance();
  43. for (int i = 1; i <= metaSize; i++) {
  44. // 获得当前列的列名
  45. String columnName = rsmd.getColumnName(i);
  46. // 根据字段名获得实体类中的字段
  47. Field field = clazz.getDeclaredField(columnName);
  48. // 设置字段可以被访问
  49. field.setAccessible(true);
  50. // 给实体中的字段赋值
  51. field.set(entity, rs.getObject(columnName));
  52. }
  53. result.add(entity);
  54. }
  55. CloseConnection(conn, pstm, rs);
  56. return result;
  57. }
  58. public static <T> T queryObject(String sql, Class<T> clazz, Object... params) throws Exception {
  59. List<T> result = queryList(sql, clazz, params);
  60. if (result != null && !result.isEmpty()) {
  61. return result.get(0);
  62. }
  63. return null;
  64. }
  65. public static int execute(String sql, Object... params) throws Exception {
  66. int rows = 0;
  67. Connection conn = null;
  68. PreparedStatement pstm = null;
  69. conn = DriverManager.getConnection(URL, USER_NAME, PASSWORD);
  70. pstm = conn.prepareStatement(sql);
  71. // 添加参数
  72. if (params != null) {
  73. for (int i = 0; i < params.length; i++) {
  74. pstm.setObject(i + 1, params[i]);
  75. }
  76. }
  77. // 执行
  78. rows = pstm.executeUpdate();
  79. CloseConnection(conn, pstm, null);
  80. return rows;
  81. }
  82. public static void CloseConnection(Connection conn, PreparedStatement pstm, ResultSet rs) throws SQLException {
  83. if (rs != null) {
  84. rs.close();
  85. }
  86. if (pstm != null) {
  87. pstm.close();
  88. }
  89. if (conn != null) {
  90. conn.close();
  91. }
  92. }
  93. }

View Code

  1. package com.zhangguo.utils;
  2. import java.util.HashMap;
  3. import java.util.Map;
  4. /**
  5. * 返回类型封装
  6. */
  7. public class R extends HashMap<String, Object> {
  8. private static final long serialVersionUID = 1L;
  9. public R() {
  10. put("code", 0);
  11. put("msg", "success");
  12. }
  13. //错误时
  14. public static R error() {
  15. return error(500, "未知异常,请联系管理员");
  16. }
  17. public static R error(String msg) {
  18. return error(500, msg);
  19. }
  20. public static R error(int code, String msg) {
  21. R r = new R();
  22. r.put("code", code);
  23. r.put("msg", msg);
  24. return r;
  25. }
  26. //成功时
  27. public static R ok(String msg) {
  28. R r = new R();
  29. r.put("msg", msg);
  30. return r;
  31. }
  32. public static R ok(Map<String, Object> map) {
  33. R r = new R();
  34. r.putAll(map);
  35. return r;
  36. }
  37. public static R ok() {
  38. return new R();
  39. }
  40. @Override
  41. public R put(String key, Object value) {
  42. super.put(key, value);
  43. return this;
  44. }
  45. }

测试:

  1. package com.zhangguo.controller;
  2. import java.util.*;
  3. import javax.servlet.annotation.WebServlet;
  4. import javax.servlet.http.HttpServletRequest;
  5. import javax.servlet.http.HttpServletResponse;
  6. import com.zhangguo.utils.DbUtils;
  7. import com.zhangguo.utils.JsonUtils;
  8. import com.zhangguo.utils.R;
  9. @WebServlet("/StudentController")
  10. public class StudentController extends BaseServlet {
  11. private static final long serialVersionUID = 1L;
  12. public void getAllStudent(HttpServletRequest request, HttpServletResponse response) {
  13. List<Student> students=null;
  14. try {
  15. students = DbUtils.queryList("select * from student", Student.class);
  16. String json = JsonUtils.toJson(students);
  17. response.getWriter().append(json);
  18. } catch (Exception e) {
  19. e.printStackTrace();
  20. }
  21. }
  22. public void getAllStus(HttpServletRequest request, HttpServletResponse response) {
  23. List<Student> students=null;
  24. try {
  25. students = DbUtils.queryList("select * from student", Student.class);
  26. R r=R.ok().put("data", students).put("time",new Date());
  27. String json = JsonUtils.toJson(r);
  28. response.getWriter().append(json);
  29. } catch (Exception e) {
  30. e.printStackTrace();
  31. }
  32. }
  33. }

运行结果:

jsonUtils:

  1. package com.zhangguo.utils;
  2. import java.text.SimpleDateFormat;
  3. import com.fasterxml.jackson.core.JsonProcessingException;
  4. import com.fasterxml.jackson.databind.ObjectMapper;
  5. public class JsonUtils {
  6. /**
  7. * 序列化成json
  8. * */
  9. public static String toJson(Object obj) {
  10. // 对象映射器
  11. ObjectMapper mapper = new ObjectMapper();
  12. SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd HH:mm:ss");
  13. mapper.setDateFormat(sdf);
  14. String result = null;
  15. // 序列化user对象为json字符串
  16. try {
  17. result = mapper.writeValueAsString(obj);
  18. } catch (JsonProcessingException e) {
  19. e.printStackTrace();
  20. }
  21. return result;
  22. }
  23. /**
  24. * 反序列化成对象
  25. * */
  26. public static <T> T toObject(String json,Class<T> valueType) {
  27. //对象映射器
  28. ObjectMapper mapper=new ObjectMapper();
  29. T result=null;
  30. try {
  31. result=mapper.readValue(json,valueType);
  32. }catch (Exception e) {
  33. e.printStackTrace();
  34. }
  35. return result;
  36. }
  37. }

View Code

baseServlet:

  1. package com.zhangguo.controller;
  2. import java.io.IOException;
  3. import java.lang.reflect.Method;
  4. import javax.servlet.ServletConfig;
  5. import javax.servlet.ServletException;
  6. import javax.servlet.annotation.WebServlet;
  7. import javax.servlet.http.HttpServlet;
  8. import javax.servlet.http.HttpServletRequest;
  9. import javax.servlet.http.HttpServletResponse;
  10. public class BaseServlet extends HttpServlet {
  11. private static final long serialVersionUID = 1L;
  12. public void init(ServletConfig config) throws ServletException {
  13. }
  14. public String commonObject;
  15. //Write once only once!
  16. protected void service(HttpServletRequest request, HttpServletResponse response)
  17. throws ServletException, IOException {
  18. String action = request.getParameter("act");
  19. request.setCharacterEncoding("utf-8");
  20. response.setCharacterEncoding("utf-8");
  21. response.setContentType("text/html;charset=utf-8");
  22. if (action != null) {
  23. try {
  24. // 在当前Servlet实例中根据action找到方法信息
  25. Method method = getClass().getDeclaredMethod(action, HttpServletRequest.class,
  26. HttpServletResponse.class);
  27. if (method != null) {
  28. // 在当前实例上调用方法method,指定参数request,response
  29. method.invoke(this, request, response);
  30. } else {
  31. response.getWriter().write("您请求的action不存在");
  32. }
  33. } catch (Exception e) {
  34. response.getWriter().write("调用发生了错误,错误:" + e.getMessage());
  35. e.printStackTrace();
  36. }
  37. } else {
  38. try {
  39. response.getWriter().write("请指定参数act");
  40. } catch (IOException e) {
  41. e.printStackTrace();
  42. }
  43. }
  44. }
  45. }

View Code

https://www.bilibili.com/video/av9219224/

7.1、请定义一个泛型类,实现简单的List功能,可变长度的数组,可以实现foreach功能。

  1. MyList<Integer> list1=new MyList<Integer>();
  2. list1.add(1);
  3. list1.add(2);
  4. list1.add(3);
  5. foreach(Integer i : list){
  6. System.out.println(i);
  7. }

7.2、请定义一个泛型方法,根据指定的类型获得方法中所有的字段、方法信息。

7.3、请使用JDBC+反射+泛型实现一个可返回强类型的方法,如:

指定SQL语句、参数与类型返回一个强类型对象

  1. List<Student> students = JDBCUtils.queryForList("select * from student where id<=?", Student.class, 10);
  2. for (Student student : students) {
  3. System.out.println(student);
  4. }

View Code

7.4、指定一个数据库,生成数据库下所有的表的实体类文件

7.5、JDBC+反射+泛型实现一个简单的ORM(选作)

  1. package model;
  2. import java.util.Date;
  3. import annotation.Column;
  4. import annotation.Entity;
  5. import annotation.Id;
  6. /**
  7. * 图书
  8. */
  9. @Entity("t_book") //表名
  10. public class Book {
  11. /**
  12. * 图书编号
  13. */
  14. @Id("t_isbn")
  15. private String isbn;
  16. /**
  17. * 书名
  18. */
  19. @Column("t_name")
  20. private String name;
  21. /**
  22. * 作者
  23. */
  24. @Column("t_author")
  25. private String author;
  26. /**
  27. * 出版社
  28. */
  29. @Column("t_publishing")
  30. private String publishing;
  31. /**
  32. * 出版时间
  33. */
  34. @Column(value = "t_pubdate")
  35. private Date pubdate;
  36. /**
  37. * 价格
  38. */
  39. @Column(value = "t_price")
  40. private double price;
  41. public String getIsbn() {
  42. return isbn;
  43. }
  44. public void setIsbn(String isbn) {
  45. this.isbn = isbn;
  46. }
  47. public String getName() {
  48. return name;
  49. }
  50. public void setName(String name) {
  51. this.name = name;
  52. }
  53. public String getAuthor() {
  54. return author;
  55. }
  56. public void setAuthor(String author) {
  57. this.author = author;
  58. }
  59. public String getPublishing() {
  60. return publishing;
  61. }
  62. public void setPublishing(String publishing) {
  63. this.publishing = publishing;
  64. }
  65. public Date getPubdate() {
  66. return pubdate;
  67. }
  68. public void setPubdate(Date pubdate) {
  69. this.pubdate = pubdate;
  70. }
  71. public double getPrice() {
  72. return price;
  73. }
  74. public void setPrice(double price) {
  75. this.price = price;
  76. }
  77. @Override
  78. public String toString() {
  79. return "书名: " + name + " 图书编号: " + isbn + " 作者: " + author
  80. + " 出版社: " + publishing + " 出版时间: " + pubdate
  81. + " 价格: " + price;
  82. }
  83. }

View Code

调用:

  1. package xml;
  2. import java.io.InputStream;
  3. import java.util.HashMap;
  4. import java.util.List;
  5. import java.util.Map;
  6. import model.Book;
  7. import org.junit.BeforeClass;
  8. import org.junit.Test;
  9. import util.DateUtils;
  10. import dao.GenericDao;
  11. import dao.JdbcGenericDaoImpl;
  12. /**
  13. * 测试泛型DAO的CRUD操作
  14. */
  15. public class GenericDaoTest {
  16. private GenericDao<Book> bookDao = new JdbcGenericDaoImpl<Book>();
  17. private static InputStream is;
  18. @BeforeClass
  19. public static void setUpBeforeClass() throws Exception {
  20. is = XmlParserTest.class.getResourceAsStream("/books.xml");
  21. }
  22. @Test
  23. public void testSave() throws Exception {
  24. List<Book> books = SaxHelper.saxReader(is);
  25. for (Book book : books) {
  26. bookDao.save(book);
  27. }
  28. }
  29. @Test
  30. public void testStudentFindAll1() throws Exception {
  31. System.out.println("\n-------------更新、删除前,测试查询所有记录--------------------");
  32. List<Book> books = bookDao.findAllByConditions(null, Book.class);
  33. for (Book book : books) {
  34. System.out.println(book);
  35. }
  36. }
  37. @Test
  38. public void testDelete() throws Exception {
  39. System.out.println("\n-------------测试删除一条记录--------------------");
  40. bookDao.delete("9787111349662",Book.class);
  41. }
  42. @Test
  43. public void testGet() throws Exception {
  44. System.out.println("\n-------------测试查询一条记录--------------------");
  45. Book book = bookDao.get("9787121025389", Book.class);
  46. System.out.println(book);
  47. }
  48. @Test
  49. public void testUpdate() throws Exception {
  50. System.out.println("\n-------------测试修改一条记录--------------------");
  51. Book book = new Book();
  52. book.setIsbn("9787121025389");
  53. book.setName("JAVA面向对象编程");
  54. book.setAuthor("孙卫琴");
  55. book.setPublishing("电子工业出版社");
  56. book.setPubdate(DateUtils.string2Date("yyyy-MM-dd", "2006-07-01"));
  57. book.setPrice(50.6);
  58. bookDao.update(book);
  59. }
  60. @Test
  61. public void testStudentFindAll2() throws Exception {
  62. System.out.println("\n-------------更新、删除前,测试根据条件查询所有记录--------------------");
  63. Map<String,Object> sqlWhereMap = new HashMap<String, Object>();
  64. //sqlWhereMap.put("t_isbn", "9787111213826");
  65. //sqlWhereMap.put("t_name", "Java");
  66. sqlWhereMap.put("t_publishing", "机械工业出版社");
  67. //sqlWhereMap.put("t_pubdate", new Date(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse("2007-01-01 12:06:00").getTime()));
  68. List<Book> books = bookDao.findAllByConditions(null, Book.class);
  69. for (Book book : books) {
  70. System.out.println(book);
  71. }
  72. }
  73. }

View Code 

参考:

https://www.cnblogs.com/sunwei2012/archive/2010/10/08/1845938.html

https://www.cnblogs.com/lwbqqyumidi/p/3837629.html

版权声明:本文为best原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/best/p/9333795.html