复制代码/
├── app1
│   ├── p_1
│   ├── p_2
│   └── p_3
└── app2

复制代码└── ./OrderNoService
        ├── A0000001
                10.0.0.1:8001
        └── A0000002
                10.0.0.2:8001

复制代码Order
    └── 3456890
        ├── 000001
        ├── 000002
        └── 000003

复制代码Queue
    └── Queue1
        ├── 000001
        ├── 000002
        └── 000003

复制代码Order
      └── OrderId
        ├── 000001
        ├── 000002
        └── 000003

routeros复制代码 1 import pygame,sys
 2 from math import *
 3 pygame.init()
 4 screen=pygame.display.set_mode((800,700),0,32)
 5 missile=pygame.image.load('element/red_pointer.png').convert_alpha()
 6 x1,y1=100,600           #导弹的初始发射位置
 7 velocity=800            #导弹速度
 8 time=1/1000             #每个时间片的长度
 9 clock=pygame.time.Clock()
10 old_angle=0
11 while True:
12     for event in pygame.event.get():
13         if event.type==pygame.QUIT:
14             sys.exit()
15     clock.tick(300)
16     x,y=pygame.mouse.get_pos()          #获取鼠标位置，鼠标就是需要打击的目标
17     distance=sqrt(pow(x1-x,2)+pow(y1-y,2))      #两点距离公式
18     section=velocity*time               #每个时间片需要移动的距离
19     sina=(y1-y)/distance
20     cosa=(x-x1)/distance
21     angle=atan2(y-y1,x-x1)              #两点线段的弧度值
22     x1,y1=(x1+section*cosa,y1-section*sina)
23     d_angle = degrees(angle)        #弧度转角度
24     screen.blit(missile, (x1-missile.get_width(), y1-missile.get_height()/2))
25     dis_angle=d_angle-old_angle          #dis_angle就是到下一个位置需要改变的角度
26     old_angle=d_angle                    #更新初始角度
27     pygame.display.update()

stylus复制代码missiled = pygame.transform.rotate(missile, -(d_angle))
screen.blit(missiled, (x1-missile.get_width(), y1-missile.get_height()/2))

css复制代码screen.blit(missiled, (x1-width+(x1-C[0]),y1-height/2+(y1-C[1])))

apache复制代码 1 import pygame,sys
 2 from math import *
 3 pygame.init()
 4 font1=pygame.font.SysFont('microsoftyaheimicrosoftyaheiui',23)
 5 textc=font1.render('*',True,(250,0,0))
 6 screen=pygame.display.set_mode((800,700),0,32)
 7 missile=pygame.image.load('element/rect1.png').convert_alpha()
 8 height=missile.get_height()
 9 width=missile.get_width()
10 pygame.mouse.set_visible(0)
11 x1,y1=100,600           #导弹的初始发射位置
12 velocity=800            #导弹速度
13 time=1/1000             #每个时间片的长度
14 clock=pygame.time.Clock()
15 A=()
16 B=()
17 C=()
18 while True:
19     for event in pygame.event.get():
20         if event.type==pygame.QUIT:
21             sys.exit()
22     clock.tick(300)
23     x,y=pygame.mouse.get_pos()          #获取鼠标位置，鼠标就是需要打击的目标
24     distance=sqrt(pow(x1-x,2)+pow(y1-y,2))      #两点距离公式
25     section=velocity*time               #每个时间片需要移动的距离
26     sina=(y1-y)/distance
27     cosa=(x-x1)/distance
28     angle=atan2(y-y1,x-x1)              #两点间线段的弧度值
29     fangle=degrees(angle)               #弧度转角度
30     x1,y1=(x1+section*cosa,y1-section*sina)
31     missiled=pygame.transform.rotate(missile,-(fangle))
32     if 0<=-fangle<=90:
33         A=(width*cosa+x1-width,y1-height/2)
34         B=(A[0]+height*sina,A[1]+height*cosa)
35 
36     if 90<-fangle<=180:
37         A = (x1 - width, y1 - height/2+height*(-cosa))
38         B = (x1 - width+height*sina, y1 - height/2)
39 
40     if -90<=-fangle<0:
41         A = (x1 - width+missiled.get_width(), y1 - height/2+missiled.get_height()-height*cosa)
42         B = (A[0]+height*sina, y1 - height/2+missiled.get_height())
43 
44     if -180<-fangle<-90:
45         A = (x1-width-height*sina, y1 - height/2+missiled.get_height())
46         B = (x1 - width,A[1]+height*cosa )
47         
48     C = ((A[0] + B[0]) / 2, (A[1] + B[1]) / 2)
49 
50     screen.fill((0,0,0))
51     screen.blit(missiled, (x1-width+(x1-C[0]),y1-height/2+(y1-C[1])))
52     screen.blit(textc, (x,y)) #鼠标用一个红色*代替
53     pygame.display.update()

复制代码  //kubernetes/pkg/kubelet/network/cni/cni.go
  func (plugin *cniNetworkPlugin) buildCNIRuntimeConf(podName string, podNs string, podSandboxID kubecontainer.ContainerID, podNetnsPath string) (*libcni.RuntimeConf, error) {
	rt := &libcni.RuntimeConf{
		ContainerID: podSandboxID.ID,
		NetNS:       podNetnsPath,
		IfName:      network.DefaultInterfaceName,
		Args: [][2]string{
			{"IgnoreUnknown", "1"},
			{"K8S_POD_NAMESPACE", podNs},
			{"K8S_POD_NAME", podName},
			{"K8S_POD_INFRA_CONTAINER_ID", podSandboxID.ID},
		},
	}

 //libcni 
func (c *CNIConfig) AddNetwork(net *NetworkConfig, rt *RuntimeConf)
  invoke.ExecPluginWithResult(pluginPath, net.Bytes, c.args("ADD", rt))
    //将RuntimeConf.Args以环境变量方式传入。
    stdoutBytes, err := e.RawExec.ExecPlugin(pluginPath, netconf, args.AsEnv())


 type CNI interface {
	AddNetworkList(net *NetworkConfigList, rt *RuntimeConf) (types.Result, error)
	DelNetworkList(net *NetworkConfigList, rt *RuntimeConf) error

	AddNetwork(net *NetworkConfig, rt *RuntimeConf) (types.Result, error)
	DelNetwork(net *NetworkConfig, rt *RuntimeConf) error
}

type RuntimeConf struct {
	ContainerID string
	NetNS       string
	IfName      string
	Args        [][2]string
	// A dictionary of capability-specific data passed by the runtime
	// to plugins as top-level keys in the 'runtimeConfig' dictionary
	// of the plugin's stdin data.  libcni will ensure that only keys
	// in this map which match the capabilities of the plugin are passed
	// to the plugin
	CapabilityArgs map[string]interface{}
}

复制代码package main
import (
    "fmt"
    "io"
    "log"
    "net/http"
    "runtime"
    "time"
)
func main() {
    runtime.GOMAXPROCS(runtime.NumCPU())
    go server()
    go printNum()
    var i = 1
    for {
        // will block here, and never go out
        i++
    }
    fmt.Println("for loop end")
    time.Sleep(time.Second * 3600)
}
func printNum() {
    i := 0
    for {
        fmt.Println(i)
        i++
    }
}
func HelloServer(w http.ResponseWriter, req *http.Request) {
    fmt.Println("hello world")
    io.WriteString(w, "hello, world!\n")
}
func server() {
    http.HandleFunc("/", HelloServer)
    err := http.ListenAndServe(":12345", nil)
    if err != nil {
        log.Fatal("ListenAndServe: ", err)
    }
}

复制代码curl localhost:12345

复制代码dlv debug hang.go

复制代码received SIGINT, stopping process (will not forward signal)> main.main() ./hang.go:17 (PC: 0x12dd7c8)
    12: func main() {
    13:         runtime.GOMAXPROCS(runtime.NumCPU())
    14:         go server()
    15:         go printNum()
    16:         var i = 1
=>  17:         for {
    18:                 // will block here, and never go out
    19:                 i++
    20:         }
    21:         fmt.Println("for loop end")
    22:         time.Sleep(time.Second * 3600)
(dlv)

复制代码package main
import (
    "fmt"
    "time"
)
func deadloop() {
    for {
    }
}
func main() {
    go deadloop()
    for {
        time.Sleep(time.Second * 1)
        fmt.Println("I got scheduled!")
    }
}

复制代码package main
import (
    "fmt"
    "log"
    "net/http"
    _ "net/http/pprof"
    // "runtime"
    "time"
)
func deadloop() {
    for {
    }
}
func main() {
    go func() {
        log.Println(http.ListenAndServe("localhost:6060", nil))
    }()
    go deadloop()
    i := 3
    for {
        time.Sleep(time.Second * 1)
        i--
        fmt.Println("I got scheduled!")
        if i == 0 {
            runtime.GC()
        }
    }
}

复制代码$ go build hang2.go
$ GODEBUG="schedtrace=300,scheddetail=1" ./hang2
SCHED 2443ms: gomaxprocs=4 idleprocs=3 threads=7 spinningthreads=0 idlethreads=2 runqueue=0 gcwaiting=0 nmidlelocked=0 stopwait=0 sysmonwait=0
  P0: status=1 schedtick=4 syscalltick=5 m=5 runqsize=0 gfreecnt=1
  P1: status=0 schedtick=14 syscalltick=0 m=-1 runqsize=0 gfreecnt=0
  P2: status=0 schedtick=3 syscalltick=4 m=-1 runqsize=0 gfreecnt=0
......  
SCHED 2751ms: gomaxprocs=4 idleprocs=0 threads=7 spinningthreads=0 idlethreads=2 runqueue=0 gcwaiting=1 nmidlelocked=0 stopwait=1 sysmonwait=0
  P0: status=1 schedtick=4 syscalltick=5 m=5 runqsize=0 gfreecnt=1
  P1: status=3 schedtick=14 syscalltick=0 m=-1 runqsize=0 gfreecnt=0
  P2: status=3 schedtick=3 syscalltick=10 m=-1 runqsize=0 gfreecnt=0
  P3: status=3 schedtick=1 syscalltick=26 m=0 runqsize=0 gfreecnt=0
  M6: p=-1 curg=-1 mallocing=0 throwing=0 preemptoff= locks=0 dying=0 helpgc=0 spinning=false blocked=false lockedg=-1
  M5: p=0 curg=19 mallocing=0 throwing=0 preemptoff= locks=0 dying=0 helpg

复制代码public abstract class AbstractObjectPool<T> {
  protected final int min;
  protected final int max;
  protected final List<T> usings = new LinkedList<>();
  protected final List<T> buffer = new LinkedList<>();
  private volatile boolean inited = false;

  public AbstractObjectPool(int min, int max) {
    this.min = min;
    this.max = max;
    if (this.min < 0 || this.min > this.max) {
      throw new IllegalArgumentException(String.format(
          "need 0 <= min <= max <= Integer.MAX_VALUE, given min: %s, max: %s", this.min, this.max));
    }
  }

  public void init() {
    for (int i = 0; i < min; i++) {
      buffer.add(newObject());
    }
    inited = true;
  }

  protected void checkInited() {
    if (!inited) {
      throw new IllegalStateException("not inited");
    }
  }

  abstract protected T newObject();

  public synchronized T getObject() {
    checkInited();

    if (usings.size() == max) {
      return null;
    }
    if (buffer.size() == 0) {
      T newObj = newObject();
      usings.add(newObj);
      return newObj;
    }
    T oldObj = buffer.remove(0);
    usings.add(oldObj);
    return oldObj;
  }

  public synchronized void freeObject(T obj) {
    checkInited();
    if (!usings.contains(obj)) {
      throw new IllegalArgumentException(String.format("obj not in using queue: %s", obj));
    }

    usings.remove(usings.indexOf(obj));
    buffer.add(obj);
  }
}

复制代码public abstract class AbstractExecutorService implements ExecutorService {
...
    public <T> Future<T> submit(Callable<T> task) {
        if (task == null) throw new NullPointerException();
        RunnableFuture<T> ftask = newTaskFor(task);
        execute(ftask);
        return ftask;
    }
...
}

复制代码public class ThreadPoolExecutor extends AbstractExecutorService {
...
    public void execute(Runnable command) {
        if (command == null)
            throw new NullPointerException();
        int c = ctl.get();
        if (workerCountOf(c) < corePoolSize) {
            if (addWorker(command, true))
                return;
            c = ctl.get();
        }
        if (isRunning(c) && workQueue.offer(command)) {
            int recheck = ctl.get();
            if (! isRunning(recheck) && remove(command))
                reject(command);
            else if (workerCountOf(recheck) == 0)
                addWorker(null, false);
        }
        else if (!addWorker(command, false))
            reject(command);
    }
...
}

复制代码public class ThreadPoolExecutor extends AbstractExecutorService {
...
    private boolean addWorker(Runnable firstTask, boolean core) {
        boolean workerStarted = false;
        boolean workerAdded = false;
        Worker w = null;
        try {
            w = new Worker(firstTask);
            final Thread t = w.thread;
            if (t != null) {
                final ReentrantLock mainLock = this.mainLock;
                mainLock.lock();
                try {
                    int rs = runStateOf(ctl.get());
                    if (rs < SHUTDOWN) {
                        workers.add(w);
                        workerAdded = true;
                    }
                } finally {
                    mainLock.unlock();
                }
                if (workerAdded) {
                    t.start();
                    workerStarted = true;
                }
            }
        } finally {
            if (! workerStarted)
                addWorkerFailed(w);
        }
        return workerStarted;
    }
...
}

复制代码private final HashSet<Worker> workers = new HashSet<Worker>();

复制代码private final class Worker
    extends AbstractQueuedSynchronizer
    implements Runnable
{
...
    Worker(Runnable firstTask) {
        setState(-1); // inhibit interrupts until runWorker
        this.firstTask = firstTask;
        this.thread = getThreadFactory().newThread(this);
    }

    /** Delegates main run loop to outer runWorker  */
    public void run() {
        runWorker(this);
    }
...
}

复制代码public class ThreadPoolExecutor extends AbstractExecutorService {
...
    final void runWorker(Worker w) {
        Thread wt = Thread.currentThread();
        Runnable task = w.firstTask;
        w.firstTask = null;
        w.unlock(); // allow interrupts
        boolean completedAbruptly = true;
        try {
            while (task != null || (task = getTask()) != null) {
                w.lock();
                try {
                    beforeExecute(wt, task);
                    Throwable thrown = null;
                    try {
                        task.run();
                    } catch (RuntimeException x) {
                        thrown = x; throw x;
                    } catch (Error x) {
                        thrown = x; throw x;
                    } catch (Throwable x) {
                        thrown = x; throw new Error(x);
                    } finally {
                        afterExecute(task, thrown);
                    }
                } finally {
                    task = null;
                    w.completedTasks++;
                    w.unlock();
                }
            }
            completedAbruptly = false;
        } finally {
            processWorkerExit(w, completedAbruptly);
        }
    }
...
}

复制代码public class ThreadPoolExecutor extends AbstractExecutorService {
...
    private Runnable getTask() {
        boolean timedOut = false;

        for (;;) {
            try {
                Runnable r = timed ?
                    workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :
                    workQueue.take();
                if (r != null)
                    return r;
                timedOut = true;
            } catch (InterruptedException retry) {
                timedOut = false;
            }
        }
    }
...
}

复制代码private final BlockingQueue<Runnable> workQueue;

复制代码public class ThreadPoolExecutor extends AbstractExecutorService {
...
    public void execute(Runnable command) {
        if (command == null)
            throw new NullPointerException();
        int c = ctl.get();
        if (workerCountOf(c) < corePoolSize) {
            if (addWorker(command, true))
                return;
            c = ctl.get();
        }
        if (isRunning(c) && workQueue.offer(command)) {
            int recheck = ctl.get();
            if (! isRunning(recheck) && remove(command))
                reject(command);
            else if (workerCountOf(recheck) == 0)
                addWorker(null, false);
        }
        else if (!addWorker(command, false))
            reject(command);
    }
...
}

复制代码package com.devcheats.multithreading.executors;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class DemoExecutorUsage {

    private static ExecutorService executor = null;
    private static volatile Future taskOneResults = null;
    private static volatile Future taskTwoResults = null;

    public static void main(String[] args) {
        executor = Executors.newFixedThreadPool(2);
        while (true) {
            try {
                checkTasks();
                Thread.sleep(1000);
            } catch (Exception e) {
                System.err.println("Caught exception: " + e.getMessage());
            }
        }
    }

    private static void checkTasks() throws Exception {
        if (taskOneResults == null
                || taskOneResults.isDone()
                || taskOneResults.isCancelled()) {
            taskOneResults = executor.submit(new TestOne());
        }

        if (taskTwoResults == null
                || taskTwoResults.isDone()
                || taskTwoResults.isCancelled()) {
            taskTwoResults = executor.submit(new TestTwo());
        }
    }
}

class TestOne implements Runnable {
    public void run() {
        while (true) {
            System.out.println("Executing task one");
            try {
                Thread.sleep(1000);
            } catch (Throwable e) {
                e.printStackTrace();
            }
        }

    }
}

class TestTwo implements Runnable {
    public void run() {
        while (true) {
            System.out.println("Executing task two");
            try {
                Thread.sleep(1000);
            } catch (Throwable e) {
                e.printStackTrace();
            }
        }
    }
}

复制代码package com.devcheats.multithreading.executors;

public class TaskOne implements Runnable {
    @Override
    public void run() {
        System.out.println("Executing Task One");
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public class TaskTwo implements Runnable {
    @Override
    public void run() {
        System.out.println("Executing Task Two");
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public class TaskThree implements Runnable {
    @Override
    public void run() {
        System.out.println("Executing Task Three");
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

复制代码package com.devcheats.demo.multithreading;

import java.util.List;

public class MultiRunnable implements Runnable {

    private final List<Runnable> runnables;

    public MultiRunnable(List<Runnable> runnables) {
        this.runnables = runnables;
    }

    @Override
    public void run() {
        for (Runnable runnable : runnables) {
             new Thread(runnable).start();
        }
    }
}

复制代码package com.devcheats.demo.multithreading;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class MultiTaskExecutor {

    public static void main(String[] args) {

        BlockingQueue<Runnable> worksQueue = new ArrayBlockingQueue<Runnable>(10);
        RejectedExecutionHandler rejectionHandler = new RejectedExecutionHandelerImpl();
        ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 3, 10, TimeUnit.SECONDS, worksQueue, rejectionHandler);

        executor.prestartAllCoreThreads();

        List<Runnable> taskGroup = new ArrayList<Runnable>();
        taskGroup.add(new TestOne());
        taskGroup.add(new TestTwo());
        taskGroup.add(new TestThree());

        worksQueue.add(new MultiRunnable(taskGroup));
    }
}

class RejectedExecutionHandelerImpl implements RejectedExecutionHandler {
    @Override
    public void rejectedExecution(Runnable runnable, ThreadPoolExecutor executor) {
        System.out.println(runnable.toString() + " : I've been rejected ! ");
    }
}

复制代码userinfo  客户信息表
 userId   客户id
 gender   性别
 brithday 出生日期

 
orderinfo 订单信息表
 orderId  订单序号（虚拟主键）
 userId   客户id
 isPaid   是否支付
 price    商品价格
 paidTime 支付时间

复制代码SELECT
    DATE_FORMAT(paidTIme, '%Y-%m') AS MT,
    count(DISTINCT userId) AS scale
    FROM
    orderinfo
    WHERE
    isPaid = '已支付'
GROUP BY
    MT

复制代码SELECT
    MONTH (paidTIme) AS MT,
    count(DISTINCT userId) AS scale
    FROM
    orderinfo
    WHERE
    isPaid = '已支付'
GROUP BY
    MT

复制代码SELECT
  COUNT(if (thr.scale!=1,1,null)) as useful,
    COUNT(*) as Fulln,
      COUNT(if( thr.scale!=1,1,null))/count(*) as ratio
      FROM
    (
         SELECT
            userId,
            count(userId) AS scale
        FROM
            db1.orderinfo
        WHERE
            MONTH (paidTime) = 3
        AND isPaid = '已支付'
        GROUP BY
            userId
    ) AS thr

复制代码SELECT 
    count(DISTINCT userId) AS allfunn,
    count(DISTINCT userId) / (
       SELECT
            count(DISTINCT userId)
       FROM
            orderinfo
        WHERE
            MONTH (paidTime) = 3
        AND isPaid = '已支付'
    ) AS ratio
        FROM
    db1.orderinfo
        WHERE
    MONTH (paidTime) = 3
AND isPaid = '已支付'
AND userId IN (
     SELECT DISTINCT
        userId
         FROM
        db1.orderinfo
    WHERE
        MONTH (paidTime) = 4
    AND isPaid = '已支付'
)

复制代码select t1.m,count(t1.m),count(t2.m) from (
   select userId,DATE_FORMAT(paidTime,'%Y-%m-01') as m from db1.orderinfo
      where isPaid = '已支付'
   group by userId,date_format(paidTime,'%Y-%m-01')) t1
      left join (
         select userId,date_format(paidTime,'%Y-%m-01') as m from db1.orderinfo
            where isPaid = '已支付'
   group by userId,date_format(paidTime,'%Y-%m-01')) t2
             on t1.userId = t2.userId
             and t1.m = date_sub(t2.m,interval 1 month)
   group by t1.m

复制代码-- 男性消费频次
SELECT
    SUM(mmg.mean) / count(*) AS mam_m
FROM
    (
        SELECT
            orderinfo.userId,
            ROUND(COUNT(orderinfo.userId), 1) AS mean
        FROM
            orderinfo
        INNER JOIN userinfo ON orderinfo.userId = userinfo.userId
        WHERE
            userinfo.gender = '男'
        GROUP BY
            orderinfo.userId
    ) AS mmg
-- 女性消费频次：
SELECT
    SUM(mmg.mean) / count(*) AS mam_m
FROM
    (
        SELECT
            orderinfo.userId,
            ROUND(COUNT(orderinfo.userId), 1) AS mean
        FROM
            orderinfo
        INNER JOIN userinfo ON orderinfo.userId = userinfo.userId
        WHERE
            userinfo.gender = '女'
        GROUP BY
            orderinfo.userId
    ) AS mmg
        
男女消费频次（老师版）：

老师首先在连接两个表的基础上，剔除了无效记录，通过count做了单个购买者的购买数量统计，
然后使用了基于性别的分组均值聚合，输出男女性平均消费频次。这个思路太棒了，我特么的就是想不到~_~

SELECT
    gender,
    AVG(ct)
FROM
    (
        SELECT
            o.userId,
            gender,
            count(1) AS ct
        FROM
            orderinfo o
        INNER JOIN (
            SELECT
                *
            FROM
                db1.userinfo
            WHERE
                gender != ''
        ) t ON o.userId = t.userId
        GROUP BY
            userId,
            gender
    ) t2
GROUP BY 
   gender

复制代码SELECT
  * FROM
    (
        SELECT
            userId,
            DATEDIFF(
                myresult.uptime,
                myresult.odtime
            ) AS difftime
        FROM
            (
                SELECT
                    lowf.userId,
                    lowf.odtime,
                    UPf.uptime
                FROM
                    (
                        SELECT
                            userId,
                            min(ldd.ltime) AS odtime
                        FROM
                            (
                                SELECT
                                    userId,
                                    paidTime AS ltime
                                FROM
                                    orderinfo
                                WHERE
                                    isPaid = '已支付'
                                ORDER BY
                                    userId,
                                    Ltime
                            ) AS ldd
                        GROUP BY
                            userId
                    ) AS lowf
                 INNER JOIN (
                    SELECT
                        userId,
                        max(pdd.ptime) AS uptime
                    FROM
                        (
                            SELECT
                                userId,
                                paidTime AS ptime
                            FROM
                                orderinfo
                            WHERE
                                isPaid = '已支付'
                            ORDER BY
                                userId,
                                ptime DESC
                        ) AS pdd
                    GROUP BY
                        userId
                ) AS UPf
              ON lowf.userId = UPf.userId
            ) AS myresult
    ) AS myresult1
WHERE
    difftime != 0

复制代码SELECT
    userId,
    min(paidTime) as mintime,
    max(paidTime) as maxtime,
    datediff(
            max(paidTime),
            min(paidTime)
    ) as difftime
    FROM
    db1.orderinfo
    WHERE
    isPaid = '已支付'
GROUP BY
    userId
    HAVING
    count(1) > 1

复制代码SELECT
    trend,
    round(avg(price), 2) AS means
    FROM
    (
        SELECT
            userId,
            btdate,
            price,
            CASE
        WHEN btdate BETWEEN '1970-01-01' AND '1979-12-31' THEN '70后'
        WHEN btdate BETWEEN '1980-01-01' AND '1989-12-31' THEN '80后'
        WHEN btdate BETWEEN '1990-01-01' AND '1999-12-31' THEN '90后'
        WHEN btdate BETWEEN '2001-01-01' AND '2009-12-31' THEN '00后'
        ELSE  '10后'
        END 
            AS 'trend'
        FROM
            (
                SELECT
                    o.userId,
                    price,
                    date(brith) AS btdate
                FROM
                    orderinfo o
                LEFT JOIN (
                    SELECT * FROM
                        db1.userinfo
                    WHERE
                        gender != ''
                ) t ON o.userId = t.userId
                WHERE
                    isPaid = '已支付'
                AND 
                date(brith) != '0000-00-00'
            ) AS mt
        ORDER BY
            userId
    ) AS outtable
GROUP BY
    trend
ORDER BY
    means

复制代码SELECT
    age,
    AVG(ct)FROM
    (
        SELECT
            o.userId,
            age,
            count(o.userId) AS ct
        FROM
            db1.orderinfo o
        INNER JOIN (
           SELECT
                userId,
                CEIL((YEAR(now()) - YEAR(brith)) / 10) AS age
             FROM
                db1.userinfo
            WHERE
                brith > '1901-00-00'
        ) AS t 
        ON o.userId = t.userId
        GROUP BY
            o.userId,
            age
    ) t2
    GROUP BY
    age

复制代码SELECT
    ceil(count(*) / 5)
FROM
    (
        SELECT
            userId,
            sum(price) AS allsp
        FROM
            orderinfo
        WHERE
            date(paidTime) != '0000-00-00'
        AND isPaid = '已支付'
        GROUP BY
            userId
        ORDER BY
            allsp DESC
    ) AS spend 
-- 17130

复制代码SELECT
        (
            SELECT
                sum(allsp) AS top20
            FROM
                (
                    SELECT
                        userId,
                        sum(price) AS allsp
                    FROM
                        orderinfo
                    WHERE
                        date(paidTime) != '0000-00-00'
                    AND isPaid = '已支付'
                    GROUP BY
                        userId
                    ORDER BY
                        allsp DESC
                    LIMIT 17130
                ) AS spend
        ) / (
             SELECT
                sum(allsp) AS entry
            FROM
                (
                    SELECT
                        userId,
                        sum(price) AS allsp
                    FROM
                        orderinfo
                    WHERE
                        date(paidTime) != '0000-00-00'
                    AND isPaid = '已支付'
                    GROUP BY
                        userId
                    ORDER BY
                        allsp DESC
                ) AS spend
        ) as top20ratio

复制代码<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-cache</artifactId>
</dependency>
<dependency>
    <groupId>net.sf.ehcache</groupId>
    <artifactId>ehcache</artifactId>
</dependency>

复制代码<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:noNamespaceSchemaLocation="ehcache.xsd">
    <cache name="department" 
           eternal="false"
           maxEntriesLocalHeap="0" 
           timeToIdleSeconds="50">
    </cache>
</ehcache>

复制代码spring.cache.type=ehcache
spring.cache.ehcache.config=classpath:ehcache.xml
# 打印日志，查看 sql
logging.level.com.light.springboot=DEBUG

复制代码@CacheConfig(cacheNames = "department")
@Service
public class DepartmentService {
    @Autowired
    private DepartmentMapper departmentMapper;
    @CachePut(key = "#department.id")
    public Department save(Department department) {
        System.out.println("保存 id=" + department.getId() + " 的数据");
        this.departmentMapper.insert(department);
        return department;
    }
    @CachePut(key = "#department.id")
    public Department update(Department department) {
        System.out.println("修改 id=" + department.getId() + " 的数据");
        this.departmentMapper.update(department);
        return department;
    }
    @Cacheable(key = "#id")
    public Department getDepartmentById(Integer id) {
        System.out.println("获取 id=" + id + " 的数据");
        Department department = this.departmentMapper.getById(id);
        return department;
    }
    @CacheEvict(key = "#id")
    public void delete(Integer id) {
        System.out.println("删除 id=" + id + " 的数据");
        this.departmentMapper.deleteById(id);
    }
}

复制代码@Controller
@RequestMapping("department")
@ResponseBody
public class DepartmentController {
    @Autowired
    private DepartmentService departmentService;
    
    @RequestMapping("save")
    public Map<String,Object> save(Department department) {
        this.departmentService.save(department);
        
        Map<String,Object> map = new HashMap<String,Object>();
        map.put("code", "200");
        map.put("msg", "保存成功");
        return map;
    }
    
    @RequestMapping("get/{id}")
    public Map<String,Object> get(@PathVariable("id") Integer id) {
        Department department = this.departmentService.getDepartmentById(id);
        
        Map<String,Object> map = new HashMap<String,Object>();
        map.put("code", "200");
        map.put("msg", "获取成功");
        map.put("data", department);
        return map;
    }
    
    @RequestMapping("update")
    public Map<String,Object> update(Department department) {
        this.departmentService.update(department);
        
        Map<String,Object> map = new HashMap<String,Object>();
        map.put("code", "200");
        map.put("msg", "修改成功");
        return map;
    }
    
    @RequestMapping("delete/{id}")
    public Map<String,Object> delete(@PathVariable("id") Integer id) {
        this.departmentService.delete(id);
        
        Map<String,Object> map = new HashMap<String,Object>();
        map.put("code", "200");
        map.put("msg", "删除成功");
        return map;
    }
}

复制代码@EnableCaching
@SpringBootApplication
public class SpringbootNosqlApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringbootNosqlApplication.class, args);
    }
}

复制代码保存 id=2 的数据
2017-12-06 14:50:48.800 DEBUG 680 --- [nio-8081-exec-7] c.l.s.dao.DepartmentMapper.insert        : ==>  Preparing: insert into department(id,name,descr) values(?,?,?) 
2017-12-06 14:50:48.801 DEBUG 680 --- [nio-8081-exec-7] c.l.s.dao.DepartmentMapper.insert        : ==> Parameters: 2(Integer), Ehcache 部门(String), Ehcache(String)
2017-12-06 14:50:48.868 DEBUG 680 --- [nio-8081-exec-7] c.l.s.dao.DepartmentMapper.insert        : <==    Updates: 1

复制代码修改 id=2 的数据
2017-12-06 14:51:16.588 DEBUG 680 --- [nio-8081-exec-8] c.l.s.dao.DepartmentMapper.update        : ==>  Preparing: update department set name = ? , descr = ? where id = ? 
2017-12-06 14:51:16.589 DEBUG 680 --- [nio-8081-exec-8] c.l.s.dao.DepartmentMapper.update        : ==> Parameters: Ehcache 部门2(String), Ehcache2(String), 2(Integer)
2017-12-06 14:51:16.657 DEBUG 680 --- [nio-8081-exec-8] c.l.s.dao.DepartmentMapper.update        : <==    Updates: 1

复制代码删除 id=2 的数据
2017-12-06 14:52:07.572 DEBUG 680 --- [nio-8081-exec-1] c.l.s.dao.DepartmentMapper.deleteById    : ==>  Preparing: delete from department where id = ? 
2017-12-06 14:52:07.572 DEBUG 680 --- [nio-8081-exec-1] c.l.s.dao.DepartmentMapper.deleteById    : ==> Parameters: 2(Integer)
2017-12-06 14:52:07.613 DEBUG 680 --- [nio-8081-exec-1] c.l.s.dao.DepartmentMapper.deleteById    : <==    Updates: 1

复制代码获取 id=2 的数据
2017-12-06 14:52:40.324 DEBUG 680 --- [nio-8081-exec-3] c.l.s.dao.DepartmentMapper.getById       : ==>  Preparing: select id,name,descr from department where id = ? 
2017-12-06 14:52:40.325 DEBUG 680 --- [nio-8081-exec-3] c.l.s.dao.DepartmentMapper.getById       : ==> Parameters: 2(Integer)
2017-12-06 14:52:40.328 DEBUG 680 --- [nio-8081-exec-3] c.l.s.dao.DepartmentMapper.getById       : <==      Total: 0

复制代码<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

复制代码spring.redis.host=192.168.2.11
spring.redis.port=6379
spring.redis.password=
spring.redis.database=0
spring.redis.pool.max-active=8
spring.redis.pool.max-idle=8
spring.redis.pool.max-wait=-1
spring.redis.pool.min-idle=0
spring.redis.timeout=0
spring.cache.type=redis
# 打印日志，查看 sql
logging.level.com.light.springboot=DEBUG

复制代码<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

复制代码spring.redis.host=192.168.2.11
spring.redis.port=6379
spring.redis.password=
spring.redis.database=0
spring.redis.pool.max-active=8
spring.redis.pool.max-idle=8
spring.redis.pool.max-wait=-1
spring.redis.pool.min-idle=0
spring.redis.timeout=0

复制代码@Component
public class RedisDao {
    
    @Autowired
    private StringRedisTemplate stringRedisTemplate;
    public void set(String key, String value) {
        this.stringRedisTemplate.opsForValue().set(key, value);
    }
    public String get(String key) {
        return this.stringRedisTemplate.opsForValue().get(key);
    }
    public void delete(String key) {
        this.stringRedisTemplate.delete(key);
    }
}

复制代码@RunWith(SpringRunner.class)
@SpringBootTest
public class RedisDaoTest {
    @Autowired
    private RedisDao redisDao;
    
    @Test
    public void testSet() {
        String key = "name";
        String value = "zhangsan";
        
        this.redisDao.set(key, value);
    }
    
    @Test
    public void testGet() {
        String key = "name";
        String value = this.redisDao.get(key);
        System.out.println(value);
    }
    
    @Test
    public void testDelete() {
        String key = "name";
        this.redisDao.delete(key);
    }
}

复制代码<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

复制代码spring.data.mongodb.host=192.168.2.25
spring.data.mongodb.port=27017
spring.data.mongodb.database=test

复制代码@Component
public class MongodbDao {
    
    @Autowired
    private MongoTemplate mongoTemplate;
    public void insert(User user) {
        this.mongoTemplate.insert(user);
    }
    public void deleteById(int id) {
        Criteria criteria = Criteria.where("id").is(id);
        Query query = new Query(criteria);
        this.mongoTemplate.remove(query, User.class);
    }
    public void update(User User) {
        Criteria criteria = Criteria.where("id").is(User.getId());
        Query query = new Query(criteria);
        Update update = new Update();
        update.set("password", User.getPassword());
        this.mongoTemplate.updateMulti(query, update, User.class);
    }
    public User getById(int id) {
        Criteria criteria = Criteria.where("id").is(id);
        Query query = new Query(criteria);
        return this.mongoTemplate.findOne(query, User.class);
    }
    
    public List<User> getAll() {
        List<User> userList = this.mongoTemplate.findAll(User.class);
        return userList;
    }
    
}

复制代码public interface UserRepository extends MongoRepository<User, Integer> {
    
}

复制代码var bytes = []byte{
16, 0, 0, 0, 0, 0, 0, 0, 
5, 0, 0, 0, 0, 0, 0, 0, 
'h', 'e', 'l', 'l', 'o'}

复制代码var ptr = &bytes[0]

复制代码type stringHeader struct {
	Data uintptr
	Len  int
}
header := (*stringHeader)(unsafe.Pointer(ptr))

复制代码header.Data = uintptr(unsafe.Pointer(&bytes[16]))

复制代码str := (*string)(unsafe.Pointer(ptr))
fmt.Println(str) // "hello"